large scala ad etl pipeline with mapreduce