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

remove unnecessary segment grouping

This commit is contained in:
xvrl 2013-02-12 09:45:26 -08:00
parent 7ab2e0552a
commit 68cd2e10a7
1 changed files with 1 additions and 11 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

12
client/src/main/java/com/metamx/druid/query/timeboundary/TimeBoundaryQueryQueryToolChest.java
View File

@ -74,19 +74,9 @@ public class TimeBoundaryQueryQueryToolChest
TimelineObjectHolder<String, ServerSelector> min = null;
TimelineObjectHolder<String, ServerSelector> max = null;
// keep track of all segments in a given shard
Map<String, Set<TimelineObjectHolder<String, ServerSelector>>> segmentGroups = Maps.newHashMap();
for(TimelineObjectHolder<String, ServerSelector> e : input) {
final long start = e.getInterval().getStartMillis();
final long end = e.getInterval().getEndMillis();
final String version = e.getVersion();
if(segmentGroups.containsKey(version)) {
segmentGroups.get(version).add(e);
} else {
segmentGroups.put(version, Sets.newHashSet(e));
}
if(min == null || start < minMillis) {
min = e;
@ -98,7 +88,7 @@ public class TimeBoundaryQueryQueryToolChest
}
}
return Lists.newArrayList(Sets.union(segmentGroups.get(min.getVersion()), segmentGroups.get(max.getVersion())));
return min == max ? Lists.newArrayList(min) : Lists.newArrayList(min , max);
}
@Override