如何檢查Spark Graphx圖形中是否存在邊緣

Question

我有一個Spark Graphx圖形，我想檢查兩個頂點之間是否存在邊。 在Spark Graphx中執行此操作的首選方法是什麼？

更具體地說，我想計算一個列表中所有頂點之間的所有邊到另一個列表中的所有頂點。

我嘗試這樣做：

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

其中ids1ids2和是包含頂點IDS兩個陣列。但這不起作用，我得到的錯誤：

org.apache.spark.SparkException: Task not serializable 

我不是很熟悉Graphx，所以任何幫助，高度讚賞。

Answer 1

這個工作對我來說：

graph.edges.filter(edge=>(ids.contains(edge.srcId) && ids.contains(edge.dstId))