车联网之电子围栏中ConnectStreamed应用二十

Posted 2023-03-03 Maynor996

文章目录

• • 1. 电子围栏中ConnectStreamed应用
  • • 1.1 ConnectedStreams简介
    • • 1.1.1 connect流说明
      • 1.1.2 connect流使用场景
    • 1.2 Broadcast+Connect+CoFlatmap+CoMap整合实战
    • 1.3 两点之间球面距离计算
    • 1.4 电子围栏中自定义对象实现CoFlatMap函数

1. 电子围栏中ConnectStreamed应用

1.1 ConnectedStreams简介

1.1.1 connect流说明

第二节学习了广播状态，广播状态把流数据广播到所有的下游task，当出现两种流数据需要进行合并与计算时，就需要用到到connect或者union

• connect operator

只能连接两个数据流