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.ensurePaths(HadoopDruidIndexerConfig config) |
static List<io.druid.timeline.DataSegment> |
IndexGeneratorJob.getPublishedSegments(HadoopDruidIndexerConfig config) |
static boolean |
JobHelper.runJobs(List<Jobby> jobs,
HadoopDruidIndexerConfig config) |
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 |
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,
String path,
Class<? extends org.apache.hadoop.mapreduce.InputFormat> inputFormatClass) |
Copyright © 2011–2015. All rights reserved.