【16】Flink 之 EventTime 和 Watermark 結合使用解決亂序數據

一、Watermark 使用分析   對於解決亂序數據問題，須要EventTime 和 Watermarks結合使用。   由【15】Flink 之 Time & EventTime & Watermarks可知，Watermarks有兩種生成方式，其中With Periodic Watermarks較爲經常使用，採用該方式進行分析。   須要實現接口AssignerWithPeriodicWat

>>阅读原文<<