l 创建90秒翻滚窗口,计算中电子围栏信息(ElectricFenceModel中的值根据车辆是否在围栏内进行设置)
设置电子围栏水印
根据vin进行分组
创建翻滚窗口,90秒为一个窗口周期
自定义窗口函数,计算电子围栏中和围栏外车辆信息
l 电子围栏分析任务中第三大步执行后的第四大步:电子围栏规则模型流生成水印、分组、创建翻滚窗口、创建窗口函数
自定义水印:ElectricFenceWatermark
根据vin进行分组:electricFenceModel.getVin
设置窗口为90间隔的翻滚窗口
自定义窗口函数:ElectricFenceWindowFunction
//TODO 4.创建90秒翻滚窗口,计算电子围栏信息(ElectricFenceModel中的值根据车辆是否在围栏内进行设置) DataStream electricFenceDataStream = efModelDataStream .assignTimestampsAndWater |
---|