Flink学习笔记(6) -- Flink Window和Time详解

一、Window(窗口)   聚合事件(比如计数、求和)在流上的工作方式与批处理不同。比如,对流中的所有元素进行计数是不可能的,因为通常流是无限的(无界的)。所以,流上的聚合需要由 window 来划定范围,比如 “计算过去的5分钟” ,或者 “最后100个元素的和” 。  window是一种可以把无限数据切割为有限数据块的手段。  窗口可以是 时间驱动的 【Time Window】(比如:每30
相关文章
相关标签/搜索