/rapido-assignment

rapido-assignment

Primary LanguageScala

Rapido Assignment

Link to dataset

Write a spark program(python or scala or any other language) to achieve the following:

  1. Calculate hourly, daily, weekly and monthly averages of aggregated counts of each customer and make this accessible for querying purposes
  2. Calculate Week-on-week cohorts for customers taking rides in that week, an example cohort output is shown as follows.