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

2023-12-13 03:59:54

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
本文来自互联网用户投稿，该文观点仅代表作者本人，不代表本站立场。本站仅提供信息存储空间服务，不拥有所有权，不承担相关法律责任。