Hi All,
I have an RDD having the data in the following form :
tempRDD: RDD[(String, (String, String))]
(brand , (product, key))
("amazon",("book1","tech"))
("eBay",("book1","tech"))
("barns&noble",("book","tech"))
("amazon",("book2","tech"))
I would like to group the data by Brand and would like to get the result
set in the following format :
resultSetRDD : RDD[(String, List[(String), (String)]
i tried using the aggregateByKey but kind of not getting how to achieve
this. OR is there any other way to achieve this?
val resultSetRDD = tempRDD.aggregateByKey("")({case (aggr , value) => aggr
+ String.valueOf(value) + ","}, (aggr1, aggr2) => aggr1 + aggr2)
resultSetRDD = (amazon,("book1","tech"),("book2","tech"))
Thanks,
Suniti
