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）與身份函數。它非常簡單。