【文件属性】：
文件名称：iot-trucking-app-flink:带有Flink的IoT货运应用程序（具有Table API和SQL）
文件大小：16KB
文件格式：ZIP
更新时间：2021-05-08 21:17:29
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)