Flink window+trigger 怎麼區別不同的數據輸出

問題需求： 我們在日常的需求中，通常會彙總計算，比如一天的數據總數 ，然後每分鐘要輸出一次結果  1）window+trigger實現，就是下面的代碼，缺點是沒辦法區分哪個輸出結果是彙總結果，可以參考下面的代碼，把窗口的end時間做一個state存儲，然後判斷大小，再輸出最後的彙總值 DataStream<String> aggregateStream = nextStream //

>>阅读原文<<