美文网首页
4、Flink 中水印是什么概念,起到什么作用?

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

作者: bigdata张凯翔 | 来源:发表于2021-01-26 15:23 被阅读0次

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


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

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

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

    相关文章

      网友评论

          本文标题:4、Flink 中水印是什么概念,起到什么作用?

          本文链接:https://www.haomeiwen.com/subject/sflmzktx.html