| 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 | 
IndexGeneratorJob.IndexGeneratorReducer.config  | 
protected HadoopDruidIndexerConfig | 
HadoopDruidIndexerMapper.config  | 
protected HadoopDruidIndexerConfig | 
DetermineHashedPartitionsJob.DetermineCardinalityReducer.config  | 
| Modifier and Type | Method and Description | 
|---|---|
static HadoopDruidIndexerConfig | 
HadoopDruidIndexerConfig.fromConfiguration(org.apache.hadoop.conf.Configuration conf)  | 
static HadoopDruidIndexerConfig | 
HadoopDruidIndexerConfig.fromDistributedFileSystem(String path)  | 
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.authenticate(HadoopDruidIndexerConfig config)
Dose authenticate against a secured hadoop cluster
 In case of any bug fix make sure to fix the code at HdfsStorageAuthentication#authenticate as well. 
 | 
static void | 
JobHelper.ensurePaths(HadoopDruidIndexerConfig config)  | 
static List<DataSegment> | 
IndexGeneratorJob.getPublishedSegments(HadoopDruidIndexerConfig config)  | 
static boolean | 
JobHelper.runJobs(List<Jobby> jobs,
       HadoopDruidIndexerConfig config)  | 
| Constructor and Description | 
|---|
DetermineHashedPartitionsJob(HadoopDruidIndexerConfig config)  | 
DeterminePartitionsDimSelectionMapperHelper(HadoopDruidIndexerConfig config,
                                           String partitionDimension)  | 
DeterminePartitionsJob(HadoopDruidIndexerConfig config)  | 
HadoopDruidDetermineConfigurationJob(HadoopDruidIndexerConfig config)  | 
HadoopDruidIndexerJob(HadoopDruidIndexerConfig config,
                     MetadataStorageUpdaterJobHandler handler)  | 
IndexGeneratorJob(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 | 
MultiplePathSpec.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)  | 
org.apache.hadoop.mapreduce.Job | 
DatasourcePathSpec.addInputPaths(HadoopDruidIndexerConfig config,
             org.apache.hadoop.mapreduce.Job job)  | 
static void | 
StaticPathSpec.addToMultipleInputs(HadoopDruidIndexerConfig config,
                   org.apache.hadoop.mapreduce.Job job,
                   Set<String> paths,
                   Class<? extends org.apache.hadoop.mapreduce.InputFormat> inputFormatClass)  | 
static void | 
StaticPathSpec.addToMultipleInputs(HadoopDruidIndexerConfig config,
                   org.apache.hadoop.mapreduce.Job job,
                   String path,
                   Class<? extends org.apache.hadoop.mapreduce.InputFormat> inputFormatClass)  | 
Copyright © 2011–2018. All rights reserved.