窗口与时间 您所在的位置:网站首页 C语言status类型 窗口与时间

窗口与时间

2023-03-17 14:57| 来源: 网络整理| 查看: 265

窗口类型

在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

 



【本文地址】

公司简介

联系我们

今日新闻

    推荐新闻

      专题文章
        CopyRight 2018-2019 实验室设备网 版权所有