Package | Description |
---|---|
io.druid.indexer | |
io.druid.indexer.partitions |
Modifier and Type | Method and Description |
---|---|
PartitionsSpec |
HadoopTuningConfig.getPartitionsSpec() |
PartitionsSpec |
HadoopDruidIndexerConfig.getPartitionsSpec() |
Constructor and Description |
---|
HadoopTuningConfig(String workingPath,
String version,
PartitionsSpec partitionsSpec,
Map<org.joda.time.DateTime,List<HadoopyShardSpec>> shardSpecs,
IndexSpec indexSpec,
Integer maxRowsInMemory,
boolean leaveIntermediate,
Boolean cleanupOnFailure,
boolean overwriteFiles,
boolean ignoreInvalidRows,
Map<String,String> jobProperties,
boolean combineText,
boolean persistInHeap,
boolean ingestOffheap,
Integer bufferSize,
Float aggregationBufferRatio,
Boolean useCombiner) |
Modifier and Type | Class and Description |
---|---|
class |
AbstractPartitionsSpec |
class |
HashedPartitionsSpec |
class |
SingleDimensionPartitionsSpec |
Copyright © 2011–2015. All rights reserved.