Streaming的窗口操作

浅谈Streaming的窗口操作

任何窗口操作需要两个参数:

  • 窗口长度:上图为3个时间单位
  • 滑动间隔:上图为2个时间单位

窗口长度 和 滑动间隔 都必须是 批处理间隔 的 整数倍。一般 滑动间隔 = 批处理间隔

一般应用场景:求近多长时间段的数据指标等?

实时处理流单词统计的窗口操作示意图:

浅谈Streaming的窗口操作

相关文章: