Flink 中的时间语义和watermark_executionconfig.setautowatermarkinterval()-CSDN博客

网友收藏2024-01-23 02:36

链接地址：https://blog.csdn.net/weixin_44966780/article/details/123310299
链接标题：Flink 中的时间语义和watermark_executionconfig.setautowatermarkinterval()-CSDN博客
所属网站：blog.csdn.net
被收藏次数：6912

文章浏览阅读68次。Flink 中的时间语义和watermark时间（Time）语义• Event Time：事件创建的时间• Ingestion Time：数据进入Flink的时间• Processing Time：执行操作算子的本地系统时间，与机器相关哪种时间语义更重要• 不同的时间语义有不同的应用场合• 我们往往更关心事件时间（Event Time）• 某些应用场合，不应该使用 Processing Time• Event Time 可以从日志数据的时间戳（timestamp）中提取➢ 2017_executionconfig.setautowatermarkinterval()

本文地址：https://tebull.com/detail/495545.html

标签：executionconfig.setautowatermarkinterval()