我有一个类似这样的RDD:
RDD[(Int, List)]]
如果 RDD 中的单个元素如下所示:
(1, List(1, 2, 3))
我的问题是如何将键值对扩展为以下形式:
(1,1)
(1,2)
(1,3)
谢谢你
我有一个类似这样的RDD:
RDD[(Int, List)]]
如果 RDD 中的单个元素如下所示:
(1, List(1, 2, 3))
(1,1)
(1,2)
(1,3)
谢谢你
rdd.flatMap { case (key, values) => values.map((key, _)) }
rdd.flatMap(lambda x: map(lambda e: (x[0], e), x[1]))