八 Flink 中的时间语义和watermark_context.timestamp和context.currentwatermark的区别-CSDN博客

网站介绍:文章浏览阅读358次。文章目录1 时间(Time)语义2 在代码中设置 Event Time3 水位线3.1 水位线的概念3.1.1 乱序数据的影响3.1.2 水位线(Watermark)3.1.3 watermark 的特点3.1.4 watermark 的传递3.1.5 水位线计算公式3.1.6 watermark 的引入3.1.6.1 TimestampAssigner3.1.6.2 实例4 watermark 的设定1 时间(Time)语义Event Time:事件创建的时间Ingestion Time:数据进入_context.timestamp和context.currentwatermark的区别