连击 天
fork: star:
Netty 线程模型 本篇文章基于Netty 4.1.56.Final Netty的线程模型是Netty高性能的关键。Netty的线程模型关乎于2个类:EventLoopGroup和EventLoop。本篇仅以NioEventLoopGroup和NioEventLoop进...
Netty ChannelPipeline 本篇文章基于Netty 4.1.56.Final 链式结构 Netty的每个channel都会拥有一个ChannelPipeline,ChannelPipeline组织编排了channel的入站和出站数据处理逻辑,是Netty处理...
Flink Task执行之数据流处理流程源码分析 从这里的分析已经知道我们编写的代码最终被封装成Flink Task并在一个while循环中由一个线程中不断执行,本篇文章将进一步了解Flink Task处理数据流的...
Flink AllowedLateness allowedLateness是Flink window中用来容忍一段时间迟到数据的,对allowedLateness最容易的误解是它等同于将watermark减去或者说推迟一段时间,通过推迟窗口触发来容忍...
Flink新内存模型 将Flink从1.7.2升级到1.10.0时出现各种内存溢出问题,Flink1.10提出了全新的内存模型,使用新版Flink理解新的内存模型是必须。对于老的flink我们一般只需配置taskmanager.h...
Kafka-Flink-Kafka End-to-End Exactly-Once End-to-End Exactly-Once 我们知道Flink的checkpoint机制实现了Flink内部的exactly-once语义。而所谓的end-to-end exactly-once即数据从数据源被...
Disruptor Disruptor是java圈子里著名的并发队列,它是一个基于生产者-消费者模型,并优化了cpu伪共享的高性能队列。要理解disruptor需要理解一下几个概念:RingBuffer,Sequence,Sequencer...
没有更多内容
加载失败,请刷新页面
没有更多内容
文章删除后无法恢复,确定删除此文章吗?
动弹删除后,数据将无法恢复
评论删除后,数据将无法恢复