版权声明:本文为博主原创文章,未经博主允许不得转载。 https://blog.csdn.net/yangguosb/article/details/85063941
流分类
- Unbounded streams:有起点没终点的数据流,对应的处理操作称为流计算;
- Bounded streams:有始有终的数据流,对应的处理操作称为批处理;
Time
-
Event Time:事件产生的时间;
-
Ingestion time:事件进入Flink的时间;
-
Processing Time:Flink开始处理事件的时间;
Windows
窗口大小
窗口大小可以从时间或空间维度来衡量,如下图所示:
时间窗口
Flink内置了3种时间窗口:Tumbling Windows、Sliding Windows和Session Windows;
- Tumbling Windows(滚动窗口): 窗口大小固定,没有重叠;
- Sliding Windows(滑动窗口):窗口大小固定,有重叠;
- Session Windows(会话窗口):窗口大小不固定,没有重叠,同一个session中所有事件分配在一个窗口;
参考: