get vertexId graphx

Question

Я новичок в spark-graphx и scala. Как я могу получить идентификатор вершины в графе?

Это мой код:

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

я заметил, что с не идентификатор sourceVertex (с = 21, а не 0)

Любые идеи? Большое спасибо

Answer 1

Идентификатор вы получаете, не VertexID но id() функция РДУ

уникальный идентификатор для этого РДУ (в пределах его SparkContext).

Поскольку вы ожидали найти только одну вершину, вы можете сделать это с помощью first вроде этого:

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