Flink 中的Watermark机制
发布时间:2022-09-02 16:59:34
发布人:wjy
Watermark是一种衡量Event Time进展的机制，可以设定延迟触发，Watermark是用于处理乱序事件的，而正确的处理乱序事件，通常用Watermark机制结合window来实现；
数据流中的Watermark用于表示timestamp小于Watermark的数据，都已经到达了，因此，window的执行也是由Watermark触发的
下一篇CEP复杂事件处理
