Flink流处理之窗口算子分析

窗口算子WindowOperator是窗口机制的底层实现，它几乎会牵扯到全部窗口相关的知识点，所以相对复杂。本文将以由面及点的方式来分析WindowOperator的实现。首先，咱们来看一下对于最多见的时间窗口（包含处理时间和事件时间）其执行示意图：java 上图中，左侧从左往右为事件流的方向。方框表明事件，事件流中夹杂着的竖直虚线表明水印，Flink经过水印分配器（TimestampsAndPe

>>阅读原文<<