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

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

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

设置电子围栏水印

根据vin进行分组

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

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

1.1 创建90秒翻滚窗口

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

自定义水印:ElectricFenceWatermark

根据vin进行分组:electricFenceModel.getVin

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

自定义窗口函数:ElectricFenceWindowFunction

//TODO 4.创建90秒翻滚窗口,计算电子围栏信息(ElectricFenceModel中的值根据车辆是否在围栏内进行设置)
DataStream electricFenceDataStream = efModelDataStream
.assignTimestampsAndWater

相关推荐

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

    2023-12-07 06:14:04       61 阅读
  2. Android 联网——CarWatchdogService介绍(

    2023-12-07 06:14:04       42 阅读
  3. Android 联网——电源管理功能扩展(

    2023-12-07 06:14:04       49 阅读
  4. 模拟电子技术实验(实验

    2023-12-07 06:14:04       36 阅读
  5. Android 联网——CarUserService介绍(三)

    2023-12-07 06:14:04       46 阅读
  6. Android 联网——CarOccupantZoneService介绍(四)

    2023-12-07 06:14:04       53 阅读
  7. Android 联网——CarDiagnosticService介绍(八)

    2023-12-07 06:14:04       57 阅读
  8. Android 联网——CarInputService介绍(七)

    2023-12-07 06:14:04       56 阅读

最近更新

  1. docker php8.1+nginx base 镜像 dockerfile 配置

    2023-12-07 06:14:04       94 阅读
  2. Could not load dynamic library ‘cudart64_100.dll‘

    2023-12-07 06:14:04       101 阅读
  3. 在Django里面运行非项目文件

    2023-12-07 06:14:04       82 阅读
  4. Python语言-面向对象

    2023-12-07 06:14:04       91 阅读

热门阅读

  1. k8s 中externalTrafficPolicy应用场景和实践

    2023-12-07 06:14:04       60 阅读
  2. logback整合rabbitmq实现消息记录日志

    2023-12-07 06:14:04       48 阅读
  3. QT使用http通信的同步和异步

    2023-12-07 06:14:04       62 阅读
  4. C++ IO库

    C++ IO库

    2023-12-07 06:14:04      42 阅读
  5. springboot引入swagger2

    2023-12-07 06:14:04       46 阅读
  6. Spark常见算子汇总

    2023-12-07 06:14:04       65 阅读
  7. DevOps搭建(三)-Docker环境安装细步骤

    2023-12-07 06:14:04       53 阅读
  8. spark log4j日志配置

    2023-12-07 06:14:04       49 阅读