diff options
| author | Ankur Dave <ankurdave@gmail.com> | 2014-01-11 00:13:49 -0800 |
|---|---|---|
| committer | Ankur Dave <ankurdave@gmail.com> | 2014-01-11 00:15:01 -0800 |
| commit | 4f7ddf40fc353ebcfd0f5dec7ea09aa90c657d32 (patch) | |
| tree | 8773b8066c378c04ef7c1783e3cdcbed69b5f10b | |
| parent | 0c9d39bbaa2a2b1b3ad6d91d2ffd864635b7f41e (diff) | |
| download | spark-4f7ddf40fc353ebcfd0f5dec7ea09aa90c657d32.tar.gz spark-4f7ddf40fc353ebcfd0f5dec7ea09aa90c657d32.tar.bz2 spark-4f7ddf40fc353ebcfd0f5dec7ea09aa90c657d32.zip | |
Optimize Edge.lexicographicOrdering
| -rw-r--r-- | graphx/src/main/scala/org/apache/spark/graphx/Edge.scala | 2 |
1 files changed, 1 insertions, 1 deletions
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 } } |