Watermark
1、Flink處理亂序資料的手段,設定事件時間戳,作為判斷标準。
2、設定延遲發車時間,等待未到的資料一段時間。
3、有周期水位線和打點水位線。
4、多路并發的時候,取所有分區水位線最小的作為标準。集合合并也是取最小的水位線。
Watermark
1、Flink處理亂序資料的手段,設定事件時間戳,作為判斷标準。
2、設定延遲發車時間,等待未到的資料一段時間。
3、有周期水位線和打點水位線。
4、多路并發的時候,取所有分區水位線最小的作為标準。集合合并也是取最小的水位線。