Count-Window案例:滚动统计窗口及滑动统计窗口的代码实现
翻滚计数窗口(无重叠数据)
按个数进行统计
案例
每隔5条统计数据,分别统计
1.全量数字之和
2.分组后每个键对应的数字之和
参考代码
滑动计数窗口(有重叠数据)
呼吁案例修改为:窗口长度是10,滑动长度是3
小结
统计窗口和时间窗口在滑动方面的功能一致,只是计量单位不同,一个是时间一个是数据条数。
要注意的是,对于分流后的数据进行窗口操作,统计窗口是每个组达到规定的数据条数后才会被触发
而时间窗每个组触发的点是一致的。这一点要注意。
