Flink ---窗口機制

背景   在流計算中，數據流是無限的，無法直接進行計算，因此Flink提出了window的概念（若干元素的集合）作爲流計算的基本單元進行數據處理。 窗口機制   窗口機制實質上是Flink的算子operator對數據流的處理過程：數據流如何被拆分成window，何時觸發計算邏輯等，如下圖所示。   處理過程： 當數據流中的元素到達算子operator後，首先由WindowAssigner決定將該元

>>阅读原文<<