Optimize Edge.lexicographicOrdering

2014-01-11 00:13:49 -08:00 · 2014-01-11 00:13:49 -08:00 · 4f7ddf40fc
parent 0c9d39bbaa
commit 4f7ddf40fc
1 changed files with 1 additions and 1 deletions
--- a/graphx/src/main/scala/org/apache/spark/graphx/Edge.scala
+++ b/graphx/src/main/scala/org/apache/spark/graphx/Edge.scala
@ -45,6 +45,6 @@ case class Edge[@specialized(Char, Int, Boolean, Byte, Long, Float, Double) ED]
 object Edge {
  def lexicographicOrdering[ED] = new Ordering[Edge[ED]] {
    override def compare(a: Edge[ED], b: Edge[ED]): Int =
-      Ordering[(VertexID, VertexID)].compare((a.srcId, a.dstId), (b.srcId, b.dstId))
+      (if (a.srcId != b.srcId) a.srcId - b.srcId else a.dstId - b.dstId).toInt
  }
 }