Flink的窗口算子 WindowOperator的實現原理

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

>>阅读原文<<