arrays - 在 Spark 中变换数组

Question

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

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

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

Answer 1

不好意思，我自己弄的。flatMap(y => y) 是否具有标识功能。就这么简单。