开发者社区> 问答> 正文

Fink中Watermark是什么?

Fink中Watermark是什么?

展开
收起
游客5n3d3br4o5qn4 2021-12-12 23:34:04 642 0
1 条回答
写回答
取消 提交回答
  • 由于实时计算的输入数据是持续不断的,因此我们需要一个有效的进度指标,来帮助我们确定关闭时间窗口的正确时间点,保证关闭窗口后不会再有数据进入该窗口,可以安全输出这个窗口的聚合结果。而Watermark就是一种衡量Event Time进展的有效机制。

    2021-12-12 23:34:34
    赞同 展开评论 打赏
问答地址:
问答排行榜
最热
最新

相关电子书

更多
任庆盛|Flink CDC + Kafka 加速业务实时化 立即下载
《基于Apache Hudi的CDC数据入湖》 立即下载
低代码开发师(初级)实战教程 立即下载