开发者社区> 问答> 正文

Flink中的窗口具体是些什么呢?

Flink中的窗口具体是些什么呢?

展开
收起
游客vwuxaq6iqaowc 2021-12-08 14:13:06 275 0
1 条回答
写回答
取消 提交回答
  • link 支持两种划分窗口的方式,按照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)

    2021-12-08 14:13:21
    赞同 展开评论 打赏
问答标签:
问答地址:
问答排行榜
最热
最新

相关电子书

更多
Flink CDC Meetup PPT - 龚中强 立即下载
Flink CDC Meetup PPT - 王赫 立即下载
Flink CDC Meetup PPT - 覃立辉 立即下载