flink一次對整個窗口進行聚合操做-ProcessWindowFunction

前面說了不少關於flink的windows相關原理的內容，今天講一個flink的window相關操做的一個實戰內容吧。java 首先，回顧一下Spark Streaming的windows操做，實際上就是在將微批增長若干倍（窗口大小處以批處理大小），這樣就造成了窗口，那對於與kafka的結合這種方式，原理我在星球的源碼裏也說過了，實際上並無真實的去kafka取數據，而是計算了offset，這種狀況

>>阅读原文<<