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

Merge pull request #57 from metamx/yops-descriptor-dimensions 

YeOldePlumberSchool: Populate dimension metadata in segment descriptor
This commit is contained in:
cheddar 2013-01-18 16:42:02 -08:00
parent 689ce4f8e1 7166534666
commit 8a8b8a59f9
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.mergeQueryableIndex(indexes, schema.getAggregators(), fileToUpload); IndexMerger.mergeQueryableIndex(indexes, schema.getAggregators(), fileToUpload);
} }
final DataSegment segmentToUpload = theSink.getSegment().withVersion(version); // Map merged segment so we can extract dimensions
final QueryableIndex mappedSegment = IndexIO.loadIndex(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(