Flink 的 window 分类?

Johngo学长 Flink 31

Flink中的窗口主要分为3大类共5种窗口

flink4

Time Window 时间窗口

  • Tumbing Time Window 滚动时间窗口
    实现统计每一分钟(或其他⻓度)窗口内 计算的效果
  • Sliding Time Window 滑动时间窗口
    实现每过xxx时间 统计 xxx时间窗口的效果. 比如,我们可以每30秒计算一次最近一分钟用户购买的商品 总数。

Count Window 计数窗口

  • Tumbing Count Window 滚动计数窗口
    当我们想要每100个用户购买行为事件统计购买总数,那么每当窗口中填满100个元素了,就会对窗口进 行计算,这种窗口我们称之为翻滚计数窗口(Tumbling Count Window)
  • Sliding Count Window 滑动计数窗口
    和Sliding Time Window含义是类似的,例如计算每10个元素计算一次最近100个元素的总和

Session Window 会话窗口

在这种用户交互事件流中,我们首先想到的是将事件聚合到会话窗口中(一段用户持续活跃的周期),由非 活跃的间隙分隔开。如上图所示,就是需要计算每个用户在活跃期间总共购买的商品数量,如果用户30秒没 有活动则视为会话断开(假设raw data stream是单个用户的购买行为流)

回复

我来回复
  • 暂无回复内容

免费咨询
免费咨询
扫码关注
扫码关注
联系站长

站长Johngo!

大数据和算法重度研究者!

持续产出大数据、算法、LeetCode干货,以及业界好资源!

2022012703491714

微信来撩,免费咨询:xiaozhu_tec

分享本页
返回顶部