文件名称：iot-trucking-app-flink:带有Flink的IoT货运应用程序（具有Table API和SQL）
文件大小：16KB
文件格式：ZIP
更新时间：2024-05-28 15:04:09
Scala
带有Flink的IoT货运应用 该项目通过Flink（主要是Flink Table API和SQL）重新实现了HDF IoT货运应用。 ，Hadoop首脑会议2017年 该项目提供了几个示例应用程序，分别利用了流流连接，窗口聚合和重复数据删除。 该项目取决于Flink 1.5.0。 应用程序取决于Truck Geo Event和Truck Speed Event，有关详细信息， 中的 。 应用程序还假定卡车地理事件和卡车速度事件都被吸收到Kafka主题中，这可以通过轻松完成。 要在此项目上运行应用程序，请按照以下步骤操作： 建立项目 sbt assembly 为输入事件和结果创建Kafka主题 $KAFKA_HOME/bin/kafka-topics.sh --create --topic truck_events_stream \ --zookeeper localhos
【文件预览】：
iot-trucking-app-flink-master
----src()
--------main()
----build.sbt(2KB)
----.gitignore(14B)
----project()
--------assembly.sbt(56B)
----README.md(3KB)