get vertexId graphx

Question

我是spark-graphx和scala中的新成员。 我怎样才能得到graphx顶点的id？

这是我的代码：

val sourceVertex=graph.vertices.filter { case (id,(_,_,_,_,_)) => id == 0} // The source vertex 
var c=sourceVertex.id 

我注意到，c是不是sourceVertex的ID（C = 21，而不是0）

任何想法？ 非常感谢

Answer 1

你得到的ID，是不是VertexID但RDD

这个RDD的唯一ID（其SparkContext内）的id()功能。

既然你希望找到只有一个顶点，则可以使用first这样做：

val sourceVertex=graph.vertices.filter { case (id,(_,_,_,_,_)) => id == 0}.first 
val c=sourceVertex._1