开发者社区> 问答> 正文

Fink中Watermark是什么?

Fink中Watermark是什么?

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

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

相关电子书

更多
Building realtime BI Systems with Kafka, Spark and Kudu 立即下载
Lego-Like Building Blocks of Storm and Spark Streaming Pipelines 立即下载
BUILDING REALTIME DATA PIPELINES WITH KAFKA CONNECT AND SPARK STREAMING 立即下载