当前位置:   article > 正文

Flink 窗口_大数据八股文

大数据八股文

Flink 窗口

窗口 (Window) : 把无界流进行切分,每一段数据分别进行聚合,结果只输出一次

Flink 窗口把流切成多个存储桶 (bucket)

image.png

窗口的驱动类型 :

  • 时间窗口 (Time Window) : 按时间段, 截取数据
  • 计数窗口 (Count Window) : 按元素数,截取数据

image.png

窗口实现

窗口实现分 :

  • 滚动窗口 (Tumbling Window) : 对数据均匀切片 , 窗口之间没有重叠 , 间隔
  • 滑动窗口 (Sliding Window) : 窗口大小 (window size) 固定,通过步长滑动 (window slide)
  • 会话窗口 (Session Window) : 按会话时间 , 对数据分组
  • 全局窗口 (Global Window) : 全局有效,将相同 key 数据 , 都分配到同个窗口 . 需自定义触发器 (Trigger)

滚动窗口 :

image.png

滑动窗口 :

image.png

会话窗口 :

image.png

全局窗口 :

image.png

声明:本文内容由网友自发贡献,版权归原作者所有,本站不承担相应法律责任。如您发现有侵权的内容,请联系我们。转载请注明出处:【wpsshop博客】
推荐阅读
相关标签
  

闽ICP备14008679号