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 |
---|
DbUpdaterJob(HadoopDruidIndexerConfig config) |
DetermineHashedPartitionsJob(HadoopDruidIndexerConfig config) |
DeterminePartitionsJob.DeterminePartitionsDimSelectionMapperHelper(HadoopDruidIndexerConfig config,
String partitionDimension) |
DeterminePartitionsJob(HadoopDruidIndexerConfig config) |
HadoopDruidDetermineConfigurationJob(HadoopDruidIndexerConfig config) |
HadoopDruidIndexerJob(HadoopDruidIndexerConfig config) |
IndexGeneratorJob(HadoopDruidIndexerConfig config) |
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.