Spark:将RDD(密钥,列表)扩展为RDD(密钥,值)

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, _)) }