public class IndexMergerV9 extends Object implements IndexMerger
IndexMerger.DictionaryMergeIterator, IndexMerger.IndexSeeker, IndexMerger.IndexSeekerWithConversion, IndexMerger.MMappedIndexRowIterable, IndexMerger.RowboatMergeFunction
INVALID_ROW, serializerUtils
Constructor and Description |
---|
IndexMergerV9(com.fasterxml.jackson.databind.ObjectMapper mapper,
IndexIO indexIO,
SegmentWriteOutMediumFactory defaultSegmentWriteOutMediumFactory) |
Modifier and Type | Method and Description |
---|---|
File |
append(List<IndexableAdapter> indexes,
AggregatorFactory[] aggregators,
File outDir,
IndexSpec indexSpec,
SegmentWriteOutMediumFactory segmentWriteOutMediumFactory) |
File |
convert(File inDir,
File outDir,
IndexSpec indexSpec) |
File |
convert(File inDir,
File outDir,
IndexSpec indexSpec,
ProgressIndicator progress,
SegmentWriteOutMediumFactory segmentWriteOutMediumFactory) |
File |
merge(List<IndexableAdapter> indexes,
boolean rollup,
AggregatorFactory[] metricAggs,
File outDir,
IndexSpec indexSpec) |
File |
mergeQueryableIndex(List<QueryableIndex> indexes,
boolean rollup,
AggregatorFactory[] metricAggs,
File outDir,
IndexSpec indexSpec,
ProgressIndicator progress,
SegmentWriteOutMediumFactory segmentWriteOutMediumFactory) |
File |
mergeQueryableIndex(List<QueryableIndex> indexes,
boolean rollup,
AggregatorFactory[] metricAggs,
File outDir,
IndexSpec indexSpec,
SegmentWriteOutMediumFactory segmentWriteOutMediumFactory) |
File |
persist(IncrementalIndex index,
File outDir,
IndexSpec indexSpec,
SegmentWriteOutMediumFactory segmentWriteOutMediumFactory) |
File |
persist(IncrementalIndex index,
org.joda.time.Interval dataInterval,
File outDir,
IndexSpec indexSpec,
ProgressIndicator progress,
SegmentWriteOutMediumFactory segmentWriteOutMediumFactory) |
File |
persist(IncrementalIndex index,
org.joda.time.Interval dataInterval,
File outDir,
IndexSpec indexSpec,
SegmentWriteOutMediumFactory segmentWriteOutMediumFactory)
This is *not* thread-safe and havok will ensue if this is called and writes are still occurring
on the IncrementalIndex object.
|
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
getLexicographicMergedDimensions, getLongestSharedDimOrder, getMergedDimensions, getMergedDimensionsFromQueryableIndexes, mergeIndexed, toIndexableAdapters
@Inject public IndexMergerV9(com.fasterxml.jackson.databind.ObjectMapper mapper, IndexIO indexIO, SegmentWriteOutMediumFactory defaultSegmentWriteOutMediumFactory)
public File persist(IncrementalIndex index, File outDir, IndexSpec indexSpec, @Nullable SegmentWriteOutMediumFactory segmentWriteOutMediumFactory) throws IOException
persist
in interface IndexMerger
IOException
public File persist(IncrementalIndex index, org.joda.time.Interval dataInterval, File outDir, IndexSpec indexSpec, @Nullable SegmentWriteOutMediumFactory segmentWriteOutMediumFactory) throws IOException
IndexMerger
persist
in interface IndexMerger
index
- the IncrementalIndex to persistdataInterval
- the Interval that the data representsoutDir
- the directory to persist the data toIOException
- if an IO error occurs persisting the indexpublic File persist(IncrementalIndex index, org.joda.time.Interval dataInterval, File outDir, IndexSpec indexSpec, ProgressIndicator progress, @Nullable SegmentWriteOutMediumFactory segmentWriteOutMediumFactory) throws IOException
persist
in interface IndexMerger
IOException
public File mergeQueryableIndex(List<QueryableIndex> indexes, boolean rollup, AggregatorFactory[] metricAggs, File outDir, IndexSpec indexSpec, @Nullable SegmentWriteOutMediumFactory segmentWriteOutMediumFactory) throws IOException
mergeQueryableIndex
in interface IndexMerger
IOException
public File mergeQueryableIndex(List<QueryableIndex> indexes, boolean rollup, AggregatorFactory[] metricAggs, File outDir, IndexSpec indexSpec, ProgressIndicator progress, @Nullable SegmentWriteOutMediumFactory segmentWriteOutMediumFactory) throws IOException
mergeQueryableIndex
in interface IndexMerger
IOException
public File merge(List<IndexableAdapter> indexes, boolean rollup, AggregatorFactory[] metricAggs, File outDir, IndexSpec indexSpec) throws IOException
merge
in interface IndexMerger
IOException
public File convert(File inDir, File outDir, IndexSpec indexSpec) throws IOException
convert
in interface IndexMerger
IOException
public File convert(File inDir, File outDir, IndexSpec indexSpec, ProgressIndicator progress, @Nullable SegmentWriteOutMediumFactory segmentWriteOutMediumFactory) throws IOException
convert
in interface IndexMerger
IOException
public File append(List<IndexableAdapter> indexes, AggregatorFactory[] aggregators, File outDir, IndexSpec indexSpec, @Nullable SegmentWriteOutMediumFactory segmentWriteOutMediumFactory) throws IOException
append
in interface IndexMerger
IOException
Copyright © 2011–2018. All rights reserved.