Flink DataStream WaterMark_watermarkstream-CSDN博客

网站介绍:文章浏览阅读693次。Flink DataStream WaterMark为了处理事件时间,Flink需要知道事件的时间戳,这意味着流中的每个元素都需要分配其事件时间戳。这通常通过从元素中的某个字段访问/提取时间戳来完成。时间戳分配与生成水印密切相关,水印告诉系统事件时间的进展。1.生成Watermark的两种方式1.1 在数据源(source)中生成WaterMarkpublic class WaterMa..._watermarkstream