全国旗舰校区

不同学习城市 同样授课品质

北京

深圳

上海

广州

郑州

大连

武汉

成都

西安

杭州

青岛

重庆

长沙

哈尔滨

南京

太原

沈阳

合肥

贵阳

济南

下一个校区
就在你家门口
+
当前位置:首页  >  应聘面试  >  大数据面试题

Flink窗口?

发布时间:2022-09-02 15:42:25
发布人:wjy

- Flink支持两种划分窗口的方式,按照time和count。

如果根据时间划分窗口,那么它就是一个time-window如果根据数据划分窗口,那么它就是一个count-window。 

- flink支持窗口的两个重要属性(size和interval) 如果size=interval,那么就会形成tumbling-window(无重叠数据)如果size>interval,那么就会形成sliding-window(有重叠数据)如果size< interval, 那么这种窗口将会丢失数据。

比如每5秒钟,统计过去3秒的通过路口汽车的数据,将会漏掉2秒钟的数据。 

通过组合可以得出四种基本窗口: 

- time-tumbling-window 无重叠数据的时间窗口,设置方式举例:timeWindow(Time.seconds(5)) 

- time-sliding-window 有重叠数据的时间窗口,

设置方式举例:timeWindow(Time.seconds(5), Time.seconds(3)) 

- count-tumbling-window无重叠数据的数量窗口

设置方式举例:countWindow(5) 

- count-sliding-window 有重叠数据的数量窗口

设置方式举例:countWindow(5,3)

Flink窗口

相关文章

大数据kafka常见面试题——如何搭建kafka?

2023-08-07

大数据kafka常见面试题——kafka中如何避免重复消费

2023-08-04

大数据面试题之多种方法创建dataframe

2023-08-02

大数据Hadoop面试题——Hadoop干什么用的?

2023-08-01

大数据行业2年工作经验的面试题有哪些?

2023-07-28

大数据kafka面试题——kafka和flume的区别是什么?

2023-07-27
在线咨询 免费试学 教程领取