Flink中的Watermark是如何工作的？

　　1、事件时间概念： 在Flink中，Watermark基于事件时间（event time）工作，这是数据本身携带的时间信息。

　　2、时间乱序处理： 由于网络延迟或其他原因，数据可能乱序到达。Watermark帮助系统判断何时一个时间窗口的数据已经全部到达，从而进行后续计算。

　　3、Watermark的生成： Watermark通常在数据源或者中间操作符中生成，它表示在这个时间戳之前的数据已经接收完毕。

　　4、触发计算： 当Watermark超过窗口结束时间时，Flink会触发窗口内的数据计算。

　　5、延迟触发： 通过设置Watermark的延迟时间，可以容忍一定程度的数据延迟，以获得更完整的结果。

很赞哦！

python编程网提示：转载请注明来源www.python66.com。
有宝贵意见可添加站长微信(底部)，获取技术资料请到公众号(底部)。同行交流请加群