Flink DataStream Window 窗口函數 ReduceFunction、AggregateFunction、ProcessWindowFunction

Window Function在窗口觸發後，負責對窗口內的元素進行計算。Window Function分爲兩類: 增量聚合和全量聚合。java 增量聚合: 窗口不維護原始數據，只維護中間結果，每次基於中間結果和增量數據進行聚合。如: ReduceFunction、AggregateFunction。 全量聚合: 窗口須要維護所有原始數據，窗口觸發進行全量聚合。如:ProcessWindowFunc

>>阅读原文<<