Flink學習筆記（七）：數據轉換過程與可選api

Flink的數據轉換過程，一般是從最開始創建一個DataStream經過一系列轉換，最終又回到DataStream，如下圖所示： 其中windowedStream的可選api有： trigger() 觸發器：定義window什麼時候關閉，觸發計算並輸出結果，例如滾動時間窗口有一個默認觸發器，它的觸發條件是時間達到endTime evitor() 移除器：定義移除某些數據的邏輯 allowedLat

>>阅读原文<<