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 收集迟到的数据 针对数据
相关文章
相关标签/搜索