| Package | Description |
|---|---|
| io.druid.segment |
| Modifier and Type | Method and Description |
|---|---|
File |
IndexMerger.append(List<IndexableAdapter> indexes,
AggregatorFactory[] aggregators,
File outDir,
IndexSpec indexSpec) |
File |
IndexMerger.append(List<IndexableAdapter> indexes,
AggregatorFactory[] aggregators,
File outDir,
IndexSpec indexSpec,
ProgressIndicator progress) |
File |
IndexMerger.convert(File inDir,
File outDir,
IndexSpec indexSpec) |
File |
IndexMerger.convert(File inDir,
File outDir,
IndexSpec indexSpec,
ProgressIndicator progress) |
boolean |
IndexIO.convertSegment(File toConvert,
File converted,
IndexSpec indexSpec) |
boolean |
IndexIO.convertSegment(File toConvert,
File converted,
IndexSpec indexSpec,
boolean forceIfCurrent,
boolean validate) |
void |
IndexIO.DefaultIndexIOHandler.convertV8toV9(File v8Dir,
File v9Dir,
IndexSpec indexSpec) |
protected File |
IndexMergerV9.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) |
protected File |
IndexMerger.makeIndexFiles(List<IndexableAdapter> indexes,
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) |
File |
IndexMerger.merge(List<IndexableAdapter> indexes,
AggregatorFactory[] metricAggs,
File outDir,
IndexSpec indexSpec) |
File |
IndexMerger.merge(List<IndexableAdapter> indexes,
AggregatorFactory[] metricAggs,
File outDir,
IndexSpec indexSpec,
ProgressIndicator progress) |
File |
IndexMerger.mergeQueryableIndex(List<QueryableIndex> indexes,
AggregatorFactory[] metricAggs,
File outDir,
IndexSpec indexSpec) |
File |
IndexMerger.mergeQueryableIndex(List<QueryableIndex> indexes,
AggregatorFactory[] metricAggs,
File outDir,
IndexSpec indexSpec,
ProgressIndicator progress) |
File |
IndexMerger.persist(IncrementalIndex index,
File outDir,
IndexSpec indexSpec) |
File |
IndexMerger.persist(IncrementalIndex index,
org.joda.time.Interval dataInterval,
File outDir,
IndexSpec indexSpec)
This is *not* thread-safe and havok will ensue if this is called and writes are still occurring
on the IncrementalIndex object.
|
File |
IndexMerger.persist(IncrementalIndex index,
org.joda.time.Interval dataInterval,
File outDir,
IndexSpec indexSpec,
ProgressIndicator progress) |
Copyright © 2011–2016. All rights reserved.