我是Flink的新手,并且正在尝试学习活动时间和水印部分。
您能解释什么是水印,以及它解决了什么问题?这个示例对我来说尚不清楚。
仅需要事件时间(过度订单处理(?
水印的目的是定义何时基于时间的窗口发射。
水印允许事件可能有些过失的想法,因此从中"提取"的时间与您想为启动该窗口的"低水"标记的位置有所不同。例如,如果您的数据是从到达之前有多种延迟的不同来源生成的(考虑分布式记录的情况(。读数。
因此,这与一些预定义的水印发电机汇总在一起,这些发电机提供了,这些发电机毫不奇怪地与选项一致。