2016-10-26 11 views
1

私はspark-graphxとscalaの新機能です。 どのようにしてgraphxの頂点のIDを得ることができましたか?vertexId graphxを取得

この私のコードは:

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

は、私は、cがsourceVertexのID(C = 21及びません0)

任意のアイデアではないことに気づきましたか? 多くのおかげ

答えて

1

あなたが取得しているIDは、VertexIDが、RDD

(そのSparkContext以内)このRDDのためのユニークなIDのid()機能ではありません。あなたが1つの頂点だけを見つけるために期待しているので

、あなたはそれがこのようなfirstを使用して行うことができます。

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

多くの感謝を...... – imen

関連する問題