收集相邻顶点graphx

Question

我正在尝试收集给定一个顶点的所有相邻顶点。但是我收到了这个错误。一个顶点的例子是 (1,"some string")

val direction: EdgeDirection = 
graph.collectNeighborIds(direction).lookup(1)

这是我的错误：

<console>:50: error: type mismatch;
found   : Seq[Array[org.apache.spark.graphx.VertexId]]
required: org.apache.spark.graphx.EdgeDirection
     graph.collectNeighborIds(direction).lookup(1)
                                               ^

Answer 1

你的代码没有任何意义。试试像

val direction: EdgeDirection = EdgeDirection.Out
val neighbourToVertexOne = graph.collectNeighborIds(direction).lookup(1)

然后对结果数组做任何你想做的事。