2017-09-25 8 views
1

Spark Graphxグラフがあり、2つの頂点の間にエッジがあるかどうかをチェックしたいのですか? Spark Graphxでこれを行うために推奨される方法は何ですか?Spark Graphxグラフにエッジが存在するかどうかを確認する方法

具体的には、あるリストのすべての頂点の間のすべての辺を別のリストのすべての頂点に数えたいと思います。

私はこれを試みた:ids1ids2が頂点IDを含む二つの配列である

graph.edges.filter { case Edge(src, dst, prop) => ids1.contains(src)&&ids2.contains(dst)}.count 

を。しかし、これは動作しませんし、私はエラーを取得する:

org.apache.spark.SparkException: Task not serializable 

私は任意の助けが高く評価されてGraphxに非常に精通していませんよ。

答えて

1

これが私の作品:

graph.edges.filter(edge=>(ids.contains(edge.srcId) && ids.contains(edge.dstId)) 
関連する問題