火花rdd如何扁平键 - 阵列（值）对

Question

我有一个公园配对rdd（键，阵列（值1，值2，值3 .....））。 我应该写什么scala语句？ 我怎么能持平RDD并创建一个新的RDD：（键，值1），（键，值2），（键，值3）....

Answer 1

rdd.flatMap{case (k,v) => v.map(vx => (k,vx))} 

Answer 2

正如@moto说，那简直就是

rdd.flatMapValues(v => v)

一个更详细的但更易读选项：

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