文章目录
-
-
- 1 Flink Watermark(水位线)
-
- 2 Flink Window Assigners(窗口分配器)
-
- 2.1 Tumbling Windows(翻滚窗口)
- 2.2 Sliding Windows(滑动窗口)
- 2.3 Session Windows(会话窗口)
- 2.4 Global Windows(全局窗口)
- 2.5 窗口函数(Window Function)
1 Flink Watermark(水位线)
1 事件时间(event time)
为了使用事件时间,Flink任务需要知道事件的时间戳