2个案例带你彻底搞懂[会话窗口]的计算实现

案例：自定义一个源，每隔随机的秒(1~10)之间产生1条数据

数据是key value，key：hadoop Spark flink 其中一个，value：是随机的数字

需求1：定义一个会话时间窗口、5秒间隙、统计全量数据之和

需求2：定义一个会话时间窗口，5秒间隙，统计按照key分组后的每组数据内的数字和

注意：会话时间窗口必须打包，不打包的话没有自带的实现方法，需要手动实现窗口自行实现