全量聚合: 窗口需要維護全部原始數據，窗口觸發進行全量聚合。 ProcessWindowFunction獲得一個包含窗口所有元素的可迭代器，以及一個具有時間和狀態信息訪問權的上下文對象，這使得它比其 ...

...

...

...

窗口的划分： 翻滾窗口（Tumbling Window，無重疊） 滾動窗口（Sliding Window，有重疊） 會話窗口（Session Window，活動間隙） 窗口的類型： 窗口在處理數據前，會對數據做分流，有兩種控制流的方式，按照數據流划分：Keyed ...

...

flatmap map window ...

不帶時間窗口的的groupby 會來一條數據進行一條數據的更新操作。這個時候結果是incrment的狀態，每次都是覆蓋（包含）了上次的結果。 帶時間窗口的groupby 會對時間窗口內的一批 ...