Apache
/
druid
mirror of https://github.com/apache/druid.git
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

Faster interval comparator (#3605)

This commit is contained in:
Navis Ryu 2016-10-26 17:50:27 +09:00 committed by Nishant
parent 98465f47b5
commit 0799640299
1 changed files with 15 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

15
java-util/src/main/java/io/druid/java/util/common/guava/Comparators.java
View File

@ -19,6 +19,7 @@
package io.druid.java.util.common.guava; package io.druid.java.util.common.guava;
import com.google.common.primitives.Longs;
import org.joda.time.DateTimeComparator; import org.joda.time.DateTimeComparator;
import org.joda.time.Interval; import org.joda.time.Interval;
@ -74,6 +75,13 @@ public class Comparators
@Override @Override
public int compare(Interval lhs, Interval rhs) public int compare(Interval lhs, Interval rhs)
{ {
if (lhs.getChronology().equals(rhs.getChronology())) {
int compare = Longs.compare(lhs.getStartMillis(), rhs.getStartMillis());
if (compare == 0) {
return Longs.compare(lhs.getEndMillis(), rhs.getEndMillis());
}
return compare;
}
int retVal = dateTimeComp.compare(lhs.getStart(), rhs.getStart()); int retVal = dateTimeComp.compare(lhs.getStart(), rhs.getStart());
if (retVal == 0) { if (retVal == 0) {
retVal = dateTimeComp.compare(lhs.getEnd(), rhs.getEnd()); retVal = dateTimeComp.compare(lhs.getEnd(), rhs.getEnd());
@ -89,6 +97,13 @@ public class Comparators
@Override @Override
public int compare(Interval lhs, Interval rhs) public int compare(Interval lhs, Interval rhs)
{ {
if (lhs.getChronology().equals(rhs.getChronology())) {
int compare = Longs.compare(lhs.getEndMillis(), rhs.getEndMillis());
if (compare == 0) {
return Longs.compare(lhs.getStartMillis(), rhs.getStartMillis());
}
return compare;
}
int retVal = dateTimeComp.compare(lhs.getEnd(), rhs.getEnd()); int retVal = dateTimeComp.compare(lhs.getEnd(), rhs.getEnd());
if (retVal == 0) { if (retVal == 0) {
retVal = dateTimeComp.compare(lhs.getStart(), rhs.getStart()); retVal = dateTimeComp.compare(lhs.getStart(), rhs.getStart());