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

YeOldePlumberSchool: Populate dimension metadata in segment descriptor

This commit is contained in:
Gian Merlino 2013-01-16 11:30:24 -08:00
parent 7e074e8158
commit 6fc350bfba
1 changed files with 8 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

9
merger/src/main/java/com/metamx/druid/merger/common/index/YeOldePlumberSchool.java
View File

@ -21,6 +21,7 @@ package com.metamx.druid.merger.common.index;
import com.google.common.base.Preconditions; import com.google.common.base.Preconditions;
import com.google.common.base.Throwables; import com.google.common.base.Throwables;
import com.google.common.collect.ImmutableList;
import com.google.common.collect.Iterables; import com.google.common.collect.Iterables;
import com.google.common.collect.Lists; import com.google.common.collect.Lists;
import com.google.common.collect.Sets; import com.google.common.collect.Sets;
@ -138,7 +139,13 @@ public class YeOldePlumberSchool implements PlumberSchool
IndexMerger.mergeMMapped(indexes, schema.getAggregators(), fileToUpload); IndexMerger.mergeMMapped(indexes, schema.getAggregators(), fileToUpload);
} }
final DataSegment segmentToUpload = theSink.getSegment().withVersion(version); // Map merged segment so we can extract dimensions
final MMappedIndex mappedSegment = IndexIO.mapDir(fileToUpload);
final DataSegment segmentToUpload = theSink.getSegment()
.withDimensions(ImmutableList.copyOf(mappedSegment.getAvailableDimensions()))
.withVersion(version);
segmentPusher.push(fileToUpload, segmentToUpload); segmentPusher.push(fileToUpload, segmentToUpload);
log.info( log.info(