For your reference:
val d1 = textFile.map(line => {
val fileds = line.split(",")
((fileds(0),fileds(1)), fileds(2).toDouble)
})
val d2 = d1.reduceByKey(_+_)
d2.foreach(println)
2014-08-28 20:04 GMT+08:00 MEETHU MATHEW <[email protected]>:
> Hi all,
>
> I have an RDD which has values in the format "id,date,cost".
>
> I want to group the elements based on the id and date columns and get the
> sum of the cost for each group.
>
> Can somebody tell me how to do this?
>
>
> Thanks & Regards,
> Meethu M
>
