public interface IndexMerger
Modifier and Type | Interface and Description |
---|---|
static class |
IndexMerger.DictionaryMergeIterator |
static interface |
IndexMerger.IndexSeeker |
static class |
IndexMerger.IndexSeekerWithConversion
Get old dictId from new dictId, and only support access in order
|
static class |
IndexMerger.MMappedIndexRowIterable |
static class |
IndexMerger.RowboatMergeFunction |
Modifier and Type | Field and Description |
---|---|
static int |
INVALID_ROW |
static Logger |
log |
static SerializerUtils |
serializerUtils |
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) |
static List<String> |
getLexicographicMergedDimensions(List<IndexableAdapter> indexes) |
static List<String> |
getLongestSharedDimOrder(List<IndexableAdapter> indexes) |
static List<String> |
getMergedDimensions(List<IndexableAdapter> indexes) |
static List<String> |
getMergedDimensionsFromQueryableIndexes(List<QueryableIndex> indexes) |
File |
merge(List<IndexableAdapter> indexes,
boolean rollup,
AggregatorFactory[] metricAggs,
File outDir,
IndexSpec indexSpec) |
static <T extends Comparable<? super T>> |
mergeIndexed(List<Iterable<T>> indexedLists) |
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.
|
static List<IndexableAdapter> |
toIndexableAdapters(List<QueryableIndex> indexes) |
static final Logger log
static final SerializerUtils serializerUtils
static final int INVALID_ROW
static List<String> getMergedDimensionsFromQueryableIndexes(List<QueryableIndex> indexes)
static List<IndexableAdapter> toIndexableAdapters(List<QueryableIndex> indexes)
static List<String> getMergedDimensions(List<IndexableAdapter> indexes)
static List<String> getLongestSharedDimOrder(List<IndexableAdapter> indexes)
static List<String> getLexicographicMergedDimensions(List<IndexableAdapter> indexes)
static <T extends Comparable<? super T>> ArrayList<T> mergeIndexed(List<Iterable<T>> indexedLists)
File persist(IncrementalIndex index, File outDir, IndexSpec indexSpec, @Nullable SegmentWriteOutMediumFactory segmentWriteOutMediumFactory) throws IOException
IOException
File persist(IncrementalIndex index, org.joda.time.Interval dataInterval, File outDir, IndexSpec indexSpec, @Nullable SegmentWriteOutMediumFactory segmentWriteOutMediumFactory) throws IOException
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 indexFile persist(IncrementalIndex index, org.joda.time.Interval dataInterval, File outDir, IndexSpec indexSpec, ProgressIndicator progress, @Nullable SegmentWriteOutMediumFactory segmentWriteOutMediumFactory) throws IOException
IOException
File mergeQueryableIndex(List<QueryableIndex> indexes, boolean rollup, AggregatorFactory[] metricAggs, File outDir, IndexSpec indexSpec, @Nullable SegmentWriteOutMediumFactory segmentWriteOutMediumFactory) throws IOException
IOException
File mergeQueryableIndex(List<QueryableIndex> indexes, boolean rollup, AggregatorFactory[] metricAggs, File outDir, IndexSpec indexSpec, ProgressIndicator progress, @Nullable SegmentWriteOutMediumFactory segmentWriteOutMediumFactory) throws IOException
IOException
File merge(List<IndexableAdapter> indexes, boolean rollup, AggregatorFactory[] metricAggs, File outDir, IndexSpec indexSpec) throws IOException
IOException
File convert(File inDir, File outDir, IndexSpec indexSpec) throws IOException
IOException
File convert(File inDir, File outDir, IndexSpec indexSpec, ProgressIndicator progress, @Nullable SegmentWriteOutMediumFactory segmentWriteOutMediumFactory) throws IOException
IOException
File append(List<IndexableAdapter> indexes, AggregatorFactory[] aggregators, File outDir, IndexSpec indexSpec, @Nullable SegmentWriteOutMediumFactory segmentWriteOutMediumFactory) throws IOException
IOException
Copyright © 2011–2018. All rights reserved.