窗口类型

在Flink计算引擎中，支持窗口类型有很多种，几乎所有Streaming流式计算引擎需要实现窗口都支持。

• 1.时间窗口TimeWindow

  

  • 按照时间间隔划分出窗口，并对窗口中数据进行计，如每m分钟统计，最近n分钟的数据
  • 划分为：滚动（Tumbling）窗口和滑动（Sliding）窗口
  • 此种方式窗口计算，在实际项目中使用较多。

• 2.计数窗口CountWindow

  

  • 按照数据条目数进行设置窗口，比如每5条数据统计一次
  • 划分为：滚动（Tumbling）窗口和滑动（Sliding）窗口
  • 此种方式窗口计算，在实际项目中使用不多，但是有些特殊业务需要使用此场景。

• 3.会话窗口SessionWindow

  

  • 会话Session相关，表示多久没有来数据，比如5秒钟都没有来数据，将前面的数据作为一个窗口
  • session 窗口，在一个固定的时间周期内不再收到元素，即非活动间隔产生，这个窗口就会关闭。
  • 一个session窗口通过一个session间隔gap来配置，这个session间隔定义了非活跃周期的长度，当这个非活跃周期产生，那么当前的session将关闭并且后续的元素将被分配到新的session窗口中去。

在Flink窗口计算中，我们发现无论时间窗口还是计数窗口，都可以分为2种类型：滚动Tumbling和滑动Sliding窗口

• 滚动窗口（Tumbling Window），又叫做翻滚窗口。滚动窗口是根据固定时间进行切分，且窗口和窗口之间的元素互不重叠。这种类型的窗口的最大特点是比较简单。只需要指定一个窗口长度（window size）。

  条件：窗口大小size = 滑动间隔 slide

• 滑动窗口（Sliding Window）

• 条件：窗口大小 != 滑动间隔，通常窗口大小size > 滑动间隔slide

  

实时效果反馈

1. 以下选项中关于Flink窗口类型的描述正确的是？

A 时间窗口：按照时间间隔划分出窗口，并对窗口中数据进行计算，如每m分钟统计，最 近n分钟的数据。

B 计数窗口：计数按照数据条目数进行设置窗口，比如每5条数据统计一次。

C 会话窗口：会话Session相关，表示多久没有来数据，比如5秒钟都没有来数据，将前面 的数据作为一个窗口。

D 以上三个选项都正确。

答案：

1=>D