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

minor optimize IndexMerger's MMappedIndexRowIterable

This commit is contained in:
binlijin 2015-12-11 15:04:46 +08:00
parent d531e69d1a
commit 362bea1090
1 changed files with 14 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

15
processing/src/main/java/io/druid/segment/IndexMerger.java
View File

@ -24,6 +24,7 @@ import com.google.common.base.Function;
import com.google.common.base.Objects; import com.google.common.base.Objects;
import com.google.common.base.Preconditions; import com.google.common.base.Preconditions;
import com.google.common.base.Splitter; import com.google.common.base.Splitter;
import com.google.common.collect.FluentIterable;
import com.google.common.collect.ImmutableList; import com.google.common.collect.ImmutableList;
import com.google.common.collect.Iterables; import com.google.common.collect.Iterables;
import com.google.common.collect.Iterators; import com.google.common.collect.Iterators;
@ -1157,6 +1158,18 @@ public class IndexMerger
@Override @Override
public Iterator<Rowboat> iterator() public Iterator<Rowboat> iterator()
{ {
final IntBuffer[] converterArray = FluentIterable
.from(convertedDims)
.transform(
new Function<String, IntBuffer>()
{
@Override
public IntBuffer apply(String input)
{
return converters.get(input);
}
}
).toArray(IntBuffer.class);
return Iterators.transform( return Iterators.transform(
index.iterator(), index.iterator(),
new Function<Rowboat, Rowboat>() new Function<Rowboat, Rowboat>()
@ -1169,7 +1182,7 @@ public class IndexMerger
int[][] dims = input.getDims(); int[][] dims = input.getDims();
int[][] newDims = new int[convertedDims.size()][]; int[][] newDims = new int[convertedDims.size()][];
for (int i = 0; i < convertedDims.size(); ++i) { for (int i = 0; i < convertedDims.size(); ++i) {
IntBuffer converter = converters.get(convertedDims.get(i)); IntBuffer converter = converterArray[i];
if (converter == null) { if (converter == null) {
continue; continue;