ApacheFlink事件时间和水印你能解释一下吗

t1rydlwq  于 2021-06-25  发布在  Flink
关注(0)|答案(1)|浏览(248)

我是新来的Flink,并试图学习事件时间和水印部分。
你能解释一下什么是水印,它解决了什么问题吗?我不清楚这个例子。
它是否只需要事件时间(无序处理)?

js81xvg6

js81xvg61#

水印的目的是定义基于时间的窗口何时触发。
水印允许这样一种想法,即事件可能稍微有点无序,因此从中“提取”的时间可能与您希望绘制触发该窗口的“低水位”标记的位置有一定的差异。例如,如果您的数据是从不同的源生成的,这些源在到达之前具有不同的延迟(考虑分布式日志记录的情况),但是,如果您的数据被保证只有递增的时间戳,例如,如果它是从传感器读数生成的,则可能不需要这样做。
所以这和flink提供的一些预定义的水印生成器是并行不悖的,这些生成器和选项是一致的。

相关问题