Flink ---窗口機制

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

>>阅读原文<<