Spark中的变换阵列

Question

val degrees: VertexRDD[Int] = graph.degrees 
val ngb=graph.collectNeighbors(EdgeDirection.Out) 
val deg2 = degrees.leftOuterJoin(ngb) 

现在我想要一个键/值对RDD，其中键是度数，值是邻居顶点ID。基本上我想从（id，数组[1,2,3]）改变为{（id，1）（id，2）（id，3）}

我试过嵌套地图并创建一个字符串为外部地图。我被困在这里。如果有人可以帮忙。提前致谢。

Answer 1

对不起，自己弄明白了。 做了flatMap（y => y）与身份函数。它非常简单。