围栏模型使用翻滚窗口【二十一】"/>
车联网之电子围栏模型使用翻滚窗口【二十一】
1. 电子围栏模型使用翻滚窗口
l 创建90秒翻滚窗口，计算中电子围栏信息(ElectricFenceModel中的值根据车辆是否在围栏内进行设置)
设置电子围栏水印
根据vin进行分组
创建翻滚窗口，90秒为一个窗口周期
自定义窗口函数，计算电子围栏中和围栏外车辆信息
1.1 创建90秒翻滚窗口
l 电子围栏分析任务中第三大步执行后的第四大步：电子围栏规则模型流生成水印、分组、创建翻滚窗口、创建窗口函数
自定义水印：ElectricFenceWatermark
根据vin进行分组：electricFenceModel.getVin
设置窗口为90间隔的翻滚窗口
自定义窗口函数：ElectricFenceWindowFunction
| //TODO 4.创建90秒翻滚窗口，计算电子围栏信息(ElectricFenceModel中的值根据车辆是否在围栏内进行设置) DataStream electricFenceDataStream = efModelDataStream .assignTimestampsAndWater |
|---|
更多推荐
车联网之电子围栏模型使用翻滚窗口【二十一】
发布评论