-
- Downloads
Add EdgeDirection.Either and use it to fix CC bug
The bug was due to a misunderstanding of the activeSetOpt parameter to Graph.mapReduceTriplets. Passing EdgeDirection.Both causes mapReduceTriplets to run only on edges with *both* vertices in the active set. This commit adds EdgeDirection.Either, which causes mapReduceTriplets to run on edges with *either* vertex in the active set. This is what connected components needed.
Showing
- graphx/src/main/scala/org/apache/spark/graphx/EdgeDirection.scala 6 additions, 2 deletions...rc/main/scala/org/apache/spark/graphx/EdgeDirection.scala
- graphx/src/main/scala/org/apache/spark/graphx/Graph.scala 6 additions, 3 deletionsgraphx/src/main/scala/org/apache/spark/graphx/Graph.scala
- graphx/src/main/scala/org/apache/spark/graphx/GraphOps.scala 21 additions, 12 deletionsgraphx/src/main/scala/org/apache/spark/graphx/GraphOps.scala
- graphx/src/main/scala/org/apache/spark/graphx/Pregel.scala 5 additions, 2 deletionsgraphx/src/main/scala/org/apache/spark/graphx/Pregel.scala
- graphx/src/main/scala/org/apache/spark/graphx/impl/GraphImpl.scala 4 additions, 0 deletions...c/main/scala/org/apache/spark/graphx/impl/GraphImpl.scala
- graphx/src/main/scala/org/apache/spark/graphx/lib/ConnectedComponents.scala 13 additions, 28 deletions...ala/org/apache/spark/graphx/lib/ConnectedComponents.scala
- graphx/src/main/scala/org/apache/spark/graphx/lib/PageRank.scala 3 additions, 2 deletions...src/main/scala/org/apache/spark/graphx/lib/PageRank.scala
- graphx/src/main/scala/org/apache/spark/graphx/lib/StronglyConnectedComponents.scala 2 additions, 1 deletion...apache/spark/graphx/lib/StronglyConnectedComponents.scala
- graphx/src/main/scala/org/apache/spark/graphx/lib/TriangleCount.scala 1 addition, 1 deletion...ain/scala/org/apache/spark/graphx/lib/TriangleCount.scala
- graphx/src/test/scala/org/apache/spark/graphx/GraphOpsSuite.scala 1 addition, 1 deletion...rc/test/scala/org/apache/spark/graphx/GraphOpsSuite.scala
- graphx/src/test/scala/org/apache/spark/graphx/PregelSuite.scala 1 addition, 1 deletion.../src/test/scala/org/apache/spark/graphx/PregelSuite.scala
- graphx/src/test/scala/org/apache/spark/graphx/lib/ConnectedComponentsSuite.scala 1 addition, 1 deletion...rg/apache/spark/graphx/lib/ConnectedComponentsSuite.scala
Loading
Please register or sign in to comment