io.druid.segment

Class IndexMergerV9

java.lang.Object

io.druid.segment.IndexMerger

io.druid.segment.IndexMergerV9

public class IndexMergerV9
extends IndexMerger

Nested Class Summary

Nested classes/interfaces inherited from class io.druid.segment.IndexMerger

IndexMerger.AggFactoryStringIndexed, IndexMerger.MMappedIndexRowIterable, IndexMerger.RowboatMergeFunction

Field Summary

Fields inherited from class io.druid.segment.IndexMerger

EMPTY_STR_DIM_VAL, indexIO, INVALID_ROW, mapper, serializerUtils, SPLITTER

Constructor Summary

Constructors

Constructor and Description
IndexMergerV9(com.fasterxml.jackson.databind.ObjectMapper mapper, IndexIO indexIO)

Method Summary

Modifier and Type	Method and Description
protected File	makeIndexFiles(List<IndexableAdapter> adapters, AggregatorFactory[] metricAggs, File outDir, ProgressIndicator progress, List<String> mergedDimensions, List<String> mergedMetrics, com.google.common.base.Function<ArrayList<Iterable<Rowboat>>,Iterable<Rowboat>> rowMergerFn, IndexSpec indexSpec)

Methods inherited from class io.druid.segment.IndexMerger

append, append, convert, convert, createIndexDrdFile, getMergedDimensions, isNullColumn, makeDimensionHandlers, makeRowIterable, merge, merge, mergeIndexed, mergeQueryableIndex, mergeQueryableIndex, persist, persist, persist

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

IndexMergerV9

@Inject
public IndexMergerV9(com.fasterxml.jackson.databind.ObjectMapper mapper,
                             IndexIO indexIO)

Method Detail

makeIndexFiles

protected File makeIndexFiles(List<IndexableAdapter> adapters,
                              AggregatorFactory[] metricAggs,
                              File outDir,
                              ProgressIndicator progress,
                              List<String> mergedDimensions,
                              List<String> mergedMetrics,
                              com.google.common.base.Function<ArrayList<Iterable<Rowboat>>,Iterable<Rowboat>> rowMergerFn,
                              IndexSpec indexSpec)
                       throws IOException

Overrides:

makeIndexFiles in class IndexMerger

Throws:

IOException