获取 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
我是 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