处理flink乱序数据
关于处理flink乱序数据比较形象的比喻:
● 乱序数据处理:
○ 水印时间:大巴车等一分钟 Watermarks
○ 允许迟到:10分钟追上大巴车还能坐 allowedLateness(Time.minutes(1))
○ 侧输出流:一班车都赶不上,自己打车(数据可以属于多个窗口,一个窗口都没赶上,才侧流输出) sideOutputLateData(lateTag)
处理flink乱序数据
关于处理flink乱序数据比较形象的比喻:
● 乱序数据处理:
○ 水印时间:大巴车等一分钟 Watermarks
○ 允许迟到:10分钟追上大巴车还能坐 allowedLateness(Time.minutes(1))
○ 侧输出流:一班车都赶不上,自己打车(数据可以属于多个窗口,一个窗口都没赶上,才侧流输出) sideOutputLateData(lateTag)