特牛生活网

flink(四):1.2版本时间、水位线讲解和代码实例_flink watermark200ms-CSDN博客

网友收藏
文章浏览阅读641次。文章目录说明水位线种类顺序事件中的Watermarks乱序事件中的Watermarks并行数据流中的Watermarks时间概念Event Timewatermark指定Timestamps总结说明本博客每周五更新一次。本博客主要讲解讲解flink时间概念和水位线相关知识,这部分是flink实时处理的核心功能,想要处理好实时和延迟数据,必须熟练掌握flink的时间概念和水位线。水位线水位线是flink的一种处理延时数据的机制,主要对设定时间内延时数据的自动容错,水位线的本质是时间戳,计算公式_flink watermark200ms