added support for random vertex cuts

2013-10-10 14:09:01 -07:00 · 2013-10-10 14:09:01 -07:00 · 8dfac4ea8f
parent 5867a824de
commit 8dfac4ea8f
1 changed files with 9 additions and 0 deletions
--- 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?
   */