水位线(水印) Watermark
和Apache Calcite基本无关,和流式SQL有关,作为附加学习内容
Watermark的概念
数据流中经常出现事件时间(Event Time)乱序的情况,如果创建一个时间窗口为5s,但是数据延迟到达,
就会引起数据的不准确,为了解决类似的问题,提出了水位线概念
Flink Watermark设计
周期Watermark (Periodic Watermark)
每个时间窗口,周期性生成watermark,和数据流中的数据事件时间没有关系
标点Watermark (Punctuated Watermark)
根据数据流中的时间,生成watermark