Flink流處理之窗口算子分析

窗口算子WindowOperator是窗口機制的底層實現，它幾乎會牽扯到全部窗口相關的知識點，所以相對複雜。本文將以由面及點的方式來分析WindowOperator的實現。首先，咱們來看一下對於最多見的時間窗口（包含處理時間和事件時間）其執行示意圖：java 上圖中，左側從左往右爲事件流的方向。方框表明事件，事件流中夾雜着的豎直虛線表明水印，Flink經過水印分配器（TimestampsAndPe

>>阅读原文<<