Code Repositories

Find and share code repositories
Check out our newest addition to the community, the Cloudera Data Analytics (CDA) group hub.
Labels (1)
Cloudera Employee
Repo Description

This project reimplements HDF IoT Trucking Apps with Spark Structured Streaming.

This project provides couple of sample applications which leverage stream-stream join, window aggregation, deduplication respectively.

This project depends on HDP version of Spark, so you may want to modify Spark version before building the project to accomodate your installation of Spark.

Apps depend on Truck Geo Event as well as Truck Speed Event, which are well explained in in sam-trucking-data-utils.

Apps also assume both truck geo events and truck speed events are ingested into Kafka topics, which can be easily done via sam-trucking-data-utils.

Detailed explanation on how to build and run is described in repo's file.

Repo Info
Github Repo URL
Github account name HeartSaVioR
Repo name iot-trucking-app-spark-structured-streaming
0 Kudos
Take a Tour of the Community
Don't have an account?
Your experience may be limited. Sign in to explore more.
Version history
Last update:
‎07-03-2018 02:14 AM
Updated by: