活动时间和水印,您可以解释一下



我是Flink的新手,并且正在尝试学习活动时间和水印部分。

您能解释什么是水印,以及它解决了什么问题?这个示例对我来说尚不清楚。

仅需要事件时间(过度订单处理(?

水印的目的是定义何时基于时间的窗口发射。

水印允许事件可能有些过失的想法,因此从中"提取"的时间与您想为启动该窗口的"低水"标记的位置有所不同。例如,如果您的数据是从到达之前有多种延迟的不同来源生成的(考虑分布式记录的情况(。读数。

因此,这与一些预定义的水印发电机汇总在一起,这些发电机提供了,这些发电机毫不奇怪地与选项一致。

相关内容

  • 没有找到相关文章

最新更新