From 4f7ddf40fc353ebcfd0f5dec7ea09aa90c657d32 Mon Sep 17 00:00:00 2001
From: Ankur Dave <ankurdave@gmail.com>
Date: Sat, 11 Jan 2014 00:13:49 -0800
Subject: [PATCH] Optimize Edge.lexicographicOrdering
---
graphx/src/main/scala/org/apache/spark/graphx/Edge.scala | 2 +-
1 file changed, 1 insertion(+), 1 deletion(-)
diff --git a/graphx/src/main/scala/org/apache/spark/graphx/Edge.scala b/graphx/src/main/scala/org/apache/spark/graphx/Edge.scala
index c6b62ebaca..b3a2a21862 100644
--- 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
}
}
--
GitLab