The pipeline process the data in AWS EMR cluster with Spark - View it on GitHub