gistfile1.scala

val data = sc.textFile("src/test/resources/*.csv")

val calls = data.map (Call(_)).cache()

val hourlyPairs = calls.map(c => (c.getHourly,c))
val weeklyPairs = calls.map(c => (c.getWeekly,c))

val groupedHourly = hourlyPairs.groupByKey()
val groupedWeekly = weeklyPairs.groupByKey()

val hourlyAggregates = groupedHourly.values.map(g => (null,CalcAggregations(g)))
val weeklyAggregates = groupedWeekly.values.map(g => (null,CalcAggregations(g)))