Watermark
1、Flink处理乱序数据的手段,设定事件时间戳,作为判断标准。
2、设定延迟发车时间,等待未到的数据一段时间。
3、有周期水位线和打点水位线。
4、多路并发的时候,取所有分区水位线最小的作为标准。集合合并也是取最小的水位线。
Watermark
1、Flink处理乱序数据的手段,设定事件时间戳,作为判断标准。
2、设定延迟发车时间,等待未到的数据一段时间。
3、有周期水位线和打点水位线。
4、多路并发的时候,取所有分区水位线最小的作为标准。集合合并也是取最小的水位线。