星火：RDD（按鍵，列表）來RDD（鍵，值）的擴展

Question

所以我有這樣的事情

RDD[(Int, List)]] 

凡在RDD一個元素看起來像

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

的RDD

我的問題是如何能在鍵值對擴展到像這樣

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

謝謝

Answer 1

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

Answer 2

而且在Python（基於@ seanowen的答案）：

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