Get CitiBike real-time data using Spark Streaming
To run the project: sbt run
myReceiver.scala: define custom receiver class for Spark Streaming
Parsing.scala: define functions parsing JSON formats
bikeJob.scala: main funciton to run Spark Streaming job and compute the time duration between the starting point and every station.