iot-trucking-app-flink:带有Flink的IoT货运应用程序（具有Table API和SQL）

带有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