窗口与时间 | 您所在的位置:网站首页 › C语言status类型 › 窗口与时间 |
窗口类型 在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 实验室设备网 版权所有 |