车联网之电子围栏模型使用翻滚窗口【二十一】

发布时间:2023年12月17日

1. 电子围栏模型使用翻滚窗口

l 创建90秒翻滚窗口,计算中电子围栏信息(ElectricFenceModel中的值根据车辆是否在围栏内进行设置)

设置电子围栏水印

根据vin进行分组

创建翻滚窗口,90秒为一个窗口周期

自定义窗口函数,计算电子围栏中和围栏外车辆信息

1.1 创建90秒翻滚窗口

l 电子围栏分析任务中第三大步执行后的第四大步:电子围栏规则模型流生成水印、分组、创建翻滚窗口、创建窗口函数

自定义水印:ElectricFenceWatermark

根据vin进行分组:electricFenceModel.getVin

设置窗口为90间隔的翻滚窗口

自定义窗口函数:ElectricFenceWindowFunction

//TODO 4.创建90秒翻滚窗口,计算电子围栏信息(ElectricFenceModel中的值根据车辆是否在围栏内进行设置)
DataStream electricFenceDataStream = efModelDataStream
.assignTimestampsAndWater
文章来源:https://blog.csdn.net/xianyu120/article/details/133949300
本文来自互联网用户投稿,该文观点仅代表作者本人,不代表本站立场。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。