滚动窗口
滚动窗口(Tumbling Windows) 滚动窗口有固定的大小,是一种对数据进行均匀切片的划分方式。窗口之间没有重叠,也不会有间隔,是“首尾相接”的状态。滚动窗口可以基于时间定义,也可以基于数据个数定义;需要的参数只有一个,就是窗口的大小(window size)。
demo演示:
场景:接收通过socket发送过来的数据,每30秒触发一次窗口计算逻辑
(1)准备一个实体对象,消息对象
package window;import java.io.Serializable;public class WaterSensor implements Serializable {private String id;private long ts;private int vc;public WaterSensor(){}public WaterSensor(String id,long ts,int vc){this.id = id;this.ts = ts;this.vc = vc;}public int getVc() {return vc;}public void setVc(int vc) {this.vc = vc;}public String getId() {return id;}public void