End to End Big data engineering project with streamed and batch data analysis using Flume, Kafka, Sqoop, Spark Streaming, Spark SQL, Hive and HBase in Scala with sample datasets.
- Load batch dimension tables data text files to MySql
- Load history tables data to MySql using Sqoop
- Stream JSON file to Kafka using Flume
- Spark Streaming to produce real time KPI's using streamed and batch data lookup.
- Spark Streaming to HBase to save streamed data
- Join 2 streams in Spark Streaming and push to Kafka Topic.
- Batch data anayisis - create fact and pivot table by combining batch and streamed data from HBase to Hive.
.png)