Flink組件三:window

3.Window CountWindow TimeWindow 滾動窗口、滑動窗口、會話session窗口 3.1window的類型 3.1.1.countWindow使用 3.2.timeWindow使用 3.3.自定義window 3.2.window聚合 3.2.1.增量聚合 窗口中每進入一條數據,就進行一次計算 reduce(reduceFunction) aggregate(aggreg
相關文章
相關標籤/搜索