窗口分类
在Flink中,窗口(Window)的作用是将无界流进行拆分,得到有限的数据集,使之变为有界流。
总的来说,Flink将窗口分为两大类。
-
基于时间驱动的
时间窗口
。例如,不管有多少数据,都是每30秒钟
创建一个窗口,然后在窗口中执行计算。 -
基于数据驱动的
计数窗口
。例如,不管多少时长,都是每10个元素
创建一个窗口,然后在窗口中执行计算。
原创大约 16 分钟
在Flink中,窗口(Window)的作用是将无界流进行拆分,得到有限的数据集,使之变为有界流。
总的来说,Flink将窗口分为两大类。
基于时间驱动的时间窗口
。例如,不管有多少数据,都是每30秒钟
创建一个窗口,然后在窗口中执行计算。
基于数据驱动的计数窗口
。例如,不管多少时长,都是每10个元素
创建一个窗口,然后在窗口中执行计算。