apache-spark - Spark : Expansion of RDD(Key, List) 到 RDD(Key, Value)

Question

所以我有一个类似这样的 RDD

RDD[(Int, List)]]

RDD 中的单个元素看起来像

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

我的问题是如何将键值对扩展为这样的

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

谢谢

Answer 1

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