4、Flink 中水印是什么概念,起到什么作用?

2021-01-26  本文已影响0人  bigdata张凯翔

4、Flink 中水印是什么概念,起到什么作用?
答:Watermark 是 Apache Flink 为了处理 EventTime 窗口计算提出的一种机制, 本质上是一种时间戳。 一般来讲Watermark经常和Window一起被用来处理乱序事件。


Watermark 是一种衡量 Event Time 进展的机制,可以设定延迟触发

Watermark 是用于处理乱序事件的,而正确的处理乱序事件,通常用Watermark 机制结合 window 来实现;

数据流中的 Watermark 用于表示 timestamp 小于 Watermark 的数据,都已经到达了,因此,window 的执行也是由 Watermark 触发的。

上一篇下一篇

猜你喜欢

热点阅读