flink水印触发窗口的机制
flink水印触发窗口的机制
水印（watermark）就是一个时间戳 ，Flink可以给数据流添加水印，可以理解为：收到一条消息后，额外给这个消息添加了一个时间字段，这就是添加水印。水印并不会影响原有Event Time。一般会设置水印时间比Event Time小几秒钟。当接收到的消息一直到水印时间 >= 窗口的 endTime ，则触发计算。
- 上一篇: flink 水印 迟到的数据
- 下一篇: flink 水印作用
水印（watermark）就是一个时间戳 ，Flink可以给数据流添加水印，可以理解为：收到一条消息后，额外给这个消息添加了一个时间字段，这就是添加水印。水印并不会影响原有Event Time。一般会设置水印时间比Event Time小几秒钟。当接收到的消息一直到水印时间 >= 窗口的 endTime ，则触发计算。