Kıvılcım: (Anahtar, Değer) RDD için (Anahtar, Liste) RDD genişletilmesi

Question

Yani RDD tek unsur

(1, List(1, 2, 3)) 

benziyor bu

RDD[(Int, List)]] 

gibi bir şey bir RDD var

sorum bu

(1,1) 
(1,2) 
(1,3) 

gibi bir şey için anahtar değer çiftini genişletebilirsiniz nasıl size

ederiz

Answer 1

rdd.flatMap { case (key, values) => values.map((key, _)) }

Answer 2

Ve Python(@ seanowen en Yanıta göre):

rdd.flatMap(lambda x: map(lambda e: (e, x[0]), x[1]))