Flink的window操做之Window Functions(二)

上一篇中介紹了Flink中的window操做,接着介紹一下窗口函數.java Window Functions 在定義了窗口分配器以後呢,咱們須要爲每個窗口明確的指定計算,這個就是窗口函數要作的事情,當系統決定一個窗口已經準備好執行以後，這個窗口函數將被用來處理窗口中的每個元素(多是分組的)。緩存 窗口函數能夠是ReduceFunction, FoldFunction , WindowFuncti

>>阅读原文<<