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 |
LegacyIndexGeneratorJob |
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–2015. All rights reserved.