場景：
視窗中每進入一條資料，就進行一次計算，等時間到了展示最後的結果。
常用的聚合算子：
（1）reduce算子
場景：視窗内元素的聚合求和
（2）aggregate算子
需求：求每隔視窗裡面的資料的平均值
等屬于視窗的資料到齊，才開始進行聚合計算【可以實作對視窗内的資料進行排序等需求】
常用算子：
兩個window之間可以進行join，join操作隻支援三種類型的window：
滾動視窗，滑動視窗，會話視窗。
使用方式：
核心思想：兩個事件流先join，然後去開窗
示例：
場景：
視窗中每進入一條資料，就進行一次計算，等時間到了展示最後的結果。
常用的聚合算子：
（1）reduce算子
場景：視窗内元素的聚合求和
（2）aggregate算子
需求：求每隔視窗裡面的資料的平均值
等屬于視窗的資料到齊，才開始進行聚合計算【可以實作對視窗内的資料進行排序等需求】
常用算子：
兩個window之間可以進行join，join操作隻支援三種類型的window：
滾動視窗，滑動視窗，會話視窗。
使用方式：
核心思想：兩個事件流先join，然後去開窗
示例：