Flink1.7.2 Source、Window数据交互源码分析

  • 时间:
  • 浏览:0
  • 来源:大发彩神幸运飞艇_大发神彩幸运飞艇官方

getBufferBuilder(targetChannel)通过channel,得到BufferBuilder,可是得到当前的partition写入数据对象BufferBuilder,其实 可是操作ResultPartition.subPartitions

每个partition写入的数据,对应到个人所有所有所有的window,另从前就实现了,在source端将数据分区,对应的window处里source对应的分区数据

record进行序列化,数据长度写进ByteBuffer lengthBuffer,数据写进ByteBuffer dataBuffer;

这是从前阻塞的措施,读取Source中对应的partition中的数据,调用BarrierTracker.getNextNonBlocked()

通知Window,有数据产生了,可需要结束英文消费了(处里数据)

经调试,按key,hash % 并行度,分配的数据如下