2016-04-04 17 views
2

にRDD(キー、一覧)の拡張だから私はRDDにおける単一の要素がスパーク:RDD(キー、値)

(1, List(1, 2, 3)) 
のように見えるこの

RDD[(Int, List)]] 

のようなもののRDDを持っています

私の質問はどのように私はこの

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

のようなものにキーと値のペアを展開することができます

ありがとうれます

答えて

6

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

0

とPythonで(@ seanowenの回答に基づいて):

rdd.flatMap(lambda x: map(lambda e: (e, x[0]), x[1])) 
関連する問題