| Package | Description | 
|---|---|
| io.druid.cli | |
| io.druid.indexer | |
| io.druid.indexer.partitions | |
| io.druid.indexer.path | 
| Modifier and Type | Method and Description | 
|---|---|
HadoopDruidIndexerConfig | 
CliInternalHadoopIndexer.getHadoopDruidIndexerConfig()  | 
| Modifier and Type | Field and Description | 
|---|---|
protected HadoopDruidIndexerConfig | 
DetermineHashedPartitionsJob.DetermineCardinalityReducer.config  | 
| Modifier and Type | Method and Description | 
|---|---|
static HadoopDruidIndexerConfig | 
HadoopDruidIndexerConfig.fromConfiguration(org.apache.hadoop.conf.Configuration conf)  | 
static HadoopDruidIndexerConfig | 
HadoopDruidIndexerConfig.fromFile(File file)  | 
static HadoopDruidIndexerConfig | 
HadoopDruidIndexerConfig.fromMap(Map<String,Object> argSpec)  | 
static HadoopDruidIndexerConfig | 
HadoopDruidIndexerConfig.fromSpec(HadoopIngestionSpec spec)  | 
static HadoopDruidIndexerConfig | 
HadoopDruidIndexerConfig.fromString(String str)  | 
HadoopDruidIndexerConfig | 
HadoopDruidIndexerMapper.getConfig()  | 
| Modifier and Type | Method and Description | 
|---|---|
static void | 
JobHelper.ensurePaths(HadoopDruidIndexerConfig config)  | 
static List<io.druid.timeline.DataSegment> | 
IndexGeneratorJob.getPublishedSegments(HadoopDruidIndexerConfig config)  | 
static boolean | 
JobHelper.runJobs(List<Jobby> jobs,
       HadoopDruidIndexerConfig config)  | 
static void | 
JobHelper.setupClasspath(HadoopDruidIndexerConfig config,
              org.apache.hadoop.mapreduce.Job groupByJob)  | 
| Constructor and Description | 
|---|
DetermineHashedPartitionsJob(HadoopDruidIndexerConfig config)  | 
DeterminePartitionsJob.DeterminePartitionsDimSelectionMapperHelper(HadoopDruidIndexerConfig config,
                                                                  String partitionDimension)  | 
DeterminePartitionsJob(HadoopDruidIndexerConfig config)  | 
HadoopDruidDetermineConfigurationJob(HadoopDruidIndexerConfig config)  | 
HadoopDruidIndexerJob(HadoopDruidIndexerConfig config,
                     MetadataStorageUpdaterJobHandler handler)  | 
IndexGeneratorJob(HadoopDruidIndexerConfig config)  | 
LegacyIndexGeneratorJob(HadoopDruidIndexerConfig config)  | 
MetadataStorageUpdaterJob(HadoopDruidIndexerConfig config,
                         MetadataStorageUpdaterJobHandler handler)  | 
| Modifier and Type | Method and Description | 
|---|---|
Jobby | 
SingleDimensionPartitionsSpec.getPartitionJob(HadoopDruidIndexerConfig config)  | 
Jobby | 
PartitionsSpec.getPartitionJob(HadoopDruidIndexerConfig config)  | 
Jobby | 
HashedPartitionsSpec.getPartitionJob(HadoopDruidIndexerConfig config)  | 
| Modifier and Type | Method and Description | 
|---|---|
org.apache.hadoop.mapreduce.Job | 
StaticPathSpec.addInputPaths(HadoopDruidIndexerConfig config,
             org.apache.hadoop.mapreduce.Job job)  | 
org.apache.hadoop.mapreduce.Job | 
PathSpec.addInputPaths(HadoopDruidIndexerConfig config,
             org.apache.hadoop.mapreduce.Job job)  | 
org.apache.hadoop.mapreduce.Job | 
GranularityPathSpec.addInputPaths(HadoopDruidIndexerConfig config,
             org.apache.hadoop.mapreduce.Job job)  | 
org.apache.hadoop.mapreduce.Job | 
GranularUnprocessedPathSpec.addInputPaths(HadoopDruidIndexerConfig config,
             org.apache.hadoop.mapreduce.Job job)  | 
Copyright © 2015. All rights reserved.