Wie transformiert man ein Objekt in RDD (Spark) in viele Elemente in RDD?

Question

Ich bekomme eine RDD mit 'Scan' Aktion von 'HBase'. Jedes Element in diesem RDD ist wie: x1, y1, y2, y3 ... So sind die Elemente in diesem RDD sind wie (jede Zeile eine Zeile Ergebnis der Scan-Aktion):

1. x1, y1, Y2, Y3
2. x2, y1, y4, y8, y9
3. x3, y5
4. ......
5. xn, y1, y6, Y100

I verwandeln wollen, dass diese RDD zu einer anderen RDD wie:

1. x1, y1
2. x1, y2
3. x1, y3
4. x2, y1
5. x2, y4
6. ...
7. xn, y1
8. xn, y6
9. xn, y100

Wie kann ich diese Transformation machen?

Answer 1

"flatMap that sh*t":

rdd.flatMap(x => { 
    val key = x.head 
    x.tail.map(y=>(key,y)) 
})