获取 vertexId graphx

get vertexId graphx

我是 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)

有什么想法吗? 非常感谢

您获得的 ID 不是 VertexID,而是 RDD

id() 函数

A unique ID for this RDD (within its SparkContext).

由于您希望只找到一个顶点,因此您可以使用 first 来做到这一点:

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