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의 아이디 (C = 21가 아니라 0)

어떤 아이디어가없는 것으로 나타났습니다? 많은 감사

Answer 1

당신이 받고있는 ID는 VertexID하지만 RDD

(그 SparkContext 이내)이 RDD에 대한 고유 ID의 id() 함수가 아닙니다. 당신은 단지 하나 개의 정점을 찾을 것으로 예상하고 있기 때문에

, 당신이이 같은 first를 사용하여 수행 할 수 있습니다

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