Flink EventTime和Watermarks案例分析

目錄 解釋： 1：實現watermark相關代碼 1.1：程序說明 1.2：代碼如下 1.3：程序詳解 2：通過數據跟蹤watermark的時間 3：watermark+window處理亂序數據 4：late element(延遲數據)的處理 4.1：丟棄(默認) 4.2：allowedLateness 指定允許數據延遲的時間 4.3：sideOutputLateData 收集遲到的數據 針對數據

>>阅读原文<<