graph - 使用 Spark 和 GraphX 查找相互边

Question

我对 spark 和 graphx 真的很陌生。我的问题是，如果我有一个图，其中一些节点之间有相互（相互）的边，我想选择性能良好的边。一个例子：

来源 Dst。

1 2

1 3

1 4

1 5

2 1

2 5

2 6

2 7

3 1

我想得到结果：

1 2

2 1

1 3

3 1

顺序可以是任意的。有谁知道我怎么能得到这个？

Answer 1

尝试：

edges.intersection(edges.map(e => Edge(e.dstId, e.srcId))

请注意，这Edge.attr也会比较这些值。如果要忽略attr值，请执行以下操作：

edges.map(e=> (e.srcId,e.dstId)).intersection(edges.map(e => (e.dstId, e.srcId)))