Package | Description |
---|---|
io.druid.indexer | |
io.druid.segment |
Modifier and Type | Method and Description |
---|---|
protected ProgressIndicator |
LegacyIndexGeneratorJob.LegacyIndexGeneratorReducer.makeProgressIndicator(org.apache.hadoop.mapreduce.Reducer.Context context) |
protected ProgressIndicator |
IndexGeneratorJob.IndexGeneratorReducer.makeProgressIndicator(org.apache.hadoop.mapreduce.Reducer.Context context) |
static ProgressIndicator |
JobHelper.progressIndicatorForContext(org.apache.hadoop.mapreduce.TaskAttemptContext context) |
Modifier and Type | Method and Description |
---|---|
protected File |
LegacyIndexGeneratorJob.LegacyIndexGeneratorReducer.mergeQueryableIndex(List<QueryableIndex> indexes,
AggregatorFactory[] aggs,
File file,
ProgressIndicator progressIndicator) |
protected File |
IndexGeneratorJob.IndexGeneratorReducer.mergeQueryableIndex(List<QueryableIndex> indexes,
AggregatorFactory[] aggs,
File file,
ProgressIndicator progressIndicator) |
protected File |
LegacyIndexGeneratorJob.LegacyIndexGeneratorReducer.persist(IncrementalIndex index,
org.joda.time.Interval interval,
File file,
ProgressIndicator progressIndicator) |
protected File |
IndexGeneratorJob.IndexGeneratorReducer.persist(IncrementalIndex index,
org.joda.time.Interval interval,
File file,
ProgressIndicator progressIndicator) |
Modifier and Type | Class and Description |
---|---|
class |
BaseProgressIndicator |
class |
LoggingProgressIndicator |
Modifier and Type | Method and Description |
---|---|
static File |
IndexMerger.append(List<IndexableAdapter> indexes,
File outDir,
IndexSpec indexSpec,
ProgressIndicator progress) |
static File |
IndexMaker.append(List<IndexableAdapter> adapters,
File outDir,
ProgressIndicator progress,
IndexSpec indexSpec) |
static File |
IndexMerger.convert(File inDir,
File outDir,
IndexSpec indexSpec,
ProgressIndicator progress) |
static File |
IndexMaker.convert(File inDir,
File outDir,
IndexSpec indexSpec,
ProgressIndicator progress) |
static File |
IndexMerger.merge(List<IndexableAdapter> indexes,
AggregatorFactory[] metricAggs,
File outDir,
IndexSpec indexSpec,
ProgressIndicator progress) |
static File |
IndexMaker.merge(List<IndexableAdapter> adapters,
AggregatorFactory[] metricAggs,
File outDir,
IndexSpec indexSpec,
ProgressIndicator progress) |
static File |
IndexMerger.mergeQueryableIndex(List<QueryableIndex> indexes,
AggregatorFactory[] metricAggs,
File outDir,
IndexSpec indexSpec,
ProgressIndicator progress) |
static File |
IndexMaker.mergeQueryableIndex(List<QueryableIndex> indexes,
AggregatorFactory[] metricAggs,
File outDir,
IndexSpec indexSpec,
ProgressIndicator progress) |
static File |
IndexMerger.persist(IncrementalIndex index,
org.joda.time.Interval dataInterval,
File outDir,
IndexSpec indexSpec,
ProgressIndicator progress) |
static File |
IndexMaker.persist(IncrementalIndex index,
org.joda.time.Interval dataInterval,
File outDir,
IndexSpec indexSpec,
ProgressIndicator progress) |
Copyright © 2011–2015. All rights reserved.