nyTaxiEventAggregatorStreaming

Spark Streaming app that collects NY City taxi trips from Kafka queue, save raw data into HDFS/Parquet and generate OLAP Cubes within Cassandra. On the other hand, there is a benchmark to compare queries in HDFS vs OLAP Cubes

Cassandra_zeppelin_NY_Taxi_Trips

Cassandra modelling and CQL statements to storage denormalized NY City taxi trips events

nytaxieventaggregator_structured

Structured Streaming Spark app that collects data from Kafka queue, save raw data into HDFS/parquet and denormalized data ordered by dimension within Cassandra