时间特性、窗口、Watermark代码实践
一、前言
二、时间特性
1 ProcessingTime 处理时间
2 EventTime 事件时间
3 IngestionTime 摄入时间
4 设置时间特性的代码
三、Window
1 代码结构
2 时间窗口
2.1 滚动时间窗口
2.2 滑动时间窗口
2.3 会话窗口
3 计数窗口
3.1 滚动计数窗口
3.2 滑动计数窗口
四、处理迟到数据
1 理想情况
2 watermark
2.1 设置事件时间和watermark
2.2 Flink1.12中设置
3 用事件时间，但不用watermark
4 allowedLateness和侧输出流
五、结语
时间特性、窗口、Watermark代码实践
一、前言
二、时间特性
1 ProcessingTim
阅读背景：
Flink教程(7) 时间特性、窗口、Watermark代码实践，支持Flink1.12
来源：互联网
分享到：
