特牛网址导航

flink watermark 生成机制与总结_flink watermark生成机制-CSDN博客

网友收藏
文章浏览阅读1.7k次,点赞3次,收藏9次。这里写目录标题watermark 介绍watermark生成方式迟到时间处理引出问题与源码分析watermark 介绍本质上watermark是flink为了处理eventTime窗口计算提出的一种机制,本质上也是一种时间戳,由flink souce或者自定义的watermark生成器按照需求定期或者按条件生成一种系统event,与普通数据流event一样流转到对应的下游operations,接收到watermark数据的operator以此不断调整自己管理的window event time cloc_flink watermark生成机制