Package | Description |
---|---|
io.druid.indexer |
Modifier and Type | Method and Description |
---|---|
HadoopyShardSpec |
HadoopDruidIndexerConfig.getShardSpec(Bucket bucket) |
Modifier and Type | Method and Description |
---|---|
Map<Long,List<HadoopyShardSpec>> |
HadoopTuningConfig.getShardSpecs() |
Modifier and Type | Method and Description |
---|---|
void |
HadoopDruidIndexerConfig.setShardSpecs(Map<Long,List<HadoopyShardSpec>> shardSpecs) |
HadoopTuningConfig |
HadoopTuningConfig.withShardSpecs(Map<Long,List<HadoopyShardSpec>> specs) |
Constructor and Description |
---|
HadoopTuningConfig(String workingPath,
String version,
PartitionsSpec partitionsSpec,
Map<Long,List<HadoopyShardSpec>> shardSpecs,
IndexSpec indexSpec,
Integer maxRowsInMemory,
boolean leaveIntermediate,
Boolean cleanupOnFailure,
boolean overwriteFiles,
boolean ignoreInvalidRows,
Map<String,String> jobProperties,
boolean combineText,
Boolean useCombiner,
Integer maxRowsInMemoryCOMPAT,
Boolean buildV9Directly,
Integer numBackgroundPersistThreads,
boolean forceExtendableShardSpecs,
boolean useExplicitVersion) |
Copyright © 2011–2017. All rights reserved.