From 8dfac4ea8f1e69894266e80f5ab8dff4c8acefdd Mon Sep 17 00:00:00 2001 From: "Joseph E. Gonzalez" Date: Thu, 10 Oct 2013 14:09:01 -0700 Subject: [PATCH] added support for random vertex cuts --- .../scala/org/apache/spark/graph/impl/GraphImpl.scala | 9 +++++++++ 1 file changed, 9 insertions(+) diff --git a/graph/src/main/scala/org/apache/spark/graph/impl/GraphImpl.scala b/graph/src/main/scala/org/apache/spark/graph/impl/GraphImpl.scala index bcb2ae1ec8..09aeade8c1 100644 --- a/graph/src/main/scala/org/apache/spark/graph/impl/GraphImpl.scala +++ b/graph/src/main/scala/org/apache/spark/graph/impl/GraphImpl.scala @@ -466,6 +466,15 @@ object GraphImpl { } + /** + * Assign edges to an aribtrary machine corresponding to a + * random vertex cut. + */ + protected def randomVertexCut(src: Vid, dst: Vid, numParts: Pid): Pid = { + math.abs((src, dst).hashCode()) % Pid + } + + /** * @todo(crankshaw) how does this effect load balancing? */