| Package | Description |
|---|---|
| io.druid.indexer | |
| io.druid.indexer.partitions |
| Modifier and Type | Class and Description |
|---|---|
class |
DetermineHashedPartitionsJob
Determines appropriate ShardSpecs for a job by determining approximate cardinality of data set using HyperLogLog
|
class |
DeterminePartitionsJob
Determines appropriate ShardSpecs for a job by determining whether or not partitioning is necessary, and if so,
choosing the best dimension that satisfies the criteria:
Must have exactly one value per row.
Must not generate oversized partitions.
|
class |
HadoopDruidDetermineConfigurationJob |
class |
HadoopDruidIndexerJob |
class |
IndexGeneratorJob |
class |
MetadataStorageUpdaterJob |
| Modifier and Type | Method and Description |
|---|---|
static boolean |
JobHelper.runJobs(List<Jobby> jobs,
HadoopDruidIndexerConfig config) |
| Modifier and Type | Method and Description |
|---|---|
Jobby |
SingleDimensionPartitionsSpec.getPartitionJob(HadoopDruidIndexerConfig config) |
Jobby |
PartitionsSpec.getPartitionJob(HadoopDruidIndexerConfig config) |
Jobby |
HashedPartitionsSpec.getPartitionJob(HadoopDruidIndexerConfig config) |
Copyright © 2011–2017. All rights reserved.