Hi,

rdd.flatMap( e => e._2.map( i => ( i, e._1)))

Should work, but I didn't test it so maybe I'm missing something.

Paolo

Inviata dal mio Windows Phone
________________________________
Da: Yifan LI<mailto:iamyifa...@gmail.com>
Inviato: ‎04/‎12/‎2014 09:27
A: user@spark.apache.org<mailto:user@spark.apache.org>
Oggetto: map function

Hi,

I have a RDD like below:
(1, (10, 20))
(2, (30, 40, 10))
(3, (30))
…

Is there any way to map it to this:
(10,1)
(20,1)
(30,2)
(40,2)
(10,2)
(30,3)
…

generally, for each element, it might be mapped to multiple.

Thanks in advance!


Best,
Yifan LI





Reply via email to