2
にRDD(キー、一覧)の拡張だから私はRDDにおける単一の要素がスパーク:RDD(キー、値)
(1, List(1, 2, 3))
のように見えるこの
RDD[(Int, List)]]
のようなもののRDDを持っています
私の質問はどのように私はこの
(1,1)
(1,2)
(1,3)
のようなものにキーと値のペアを展開することができます
ありがとうれますにRDD(キー、一覧)の拡張だから私はRDDにおける単一の要素がスパーク:RDD(キー、値)
(1, List(1, 2, 3))
のように見えるこの
RDD[(Int, List)]]
のようなもののRDDを持っています
私の質問はどのように私はこの
(1,1)
(1,2)
(1,3)
のようなものにキーと値のペアを展開することができます
ありがとうれますrdd.flatMap { case (key, values) => values.map((key, _)) }
とPythonで(@ seanowenの回答に基づいて):
rdd.flatMap(lambda x: map(lambda e: (e, x[0]), x[1]))