A Real-Time Distributed Stream Processing and Graph Analytics Pipeline using Apache Kafka, Spark Structured Streaming, Spark SQL, RDDs, MLlib, and GraphX.
