Flink窗口函數(window function) 詳解及代碼演示

1、概念 在定義好了窗口以後，須要指定對每一個窗口的計算邏輯。 Window Function 有四種： ReduceFunction AggregateFunction FoldFunction ProcessWindowFunction 前面兩個會執行的更加有效率，由於在元素到來時，Flink 能夠增量的把元素聚合到每一個窗口上。 ProcessWindowFunction 提供了一個 Ite

>>阅读原文<<