| Package | Description |
|---|---|
| io.druid.indexer | |
| io.druid.indexer.partitions |
| Modifier and Type | Method and Description |
|---|---|
PartitionsSpec |
HadoopTuningConfig.getPartitionsSpec() |
PartitionsSpec |
HadoopDruidIndexerConfig.getPartitionsSpec() |
| Constructor and Description |
|---|
HadoopIngestionSpec(DataSchema dataSchema,
HadoopIOConfig ioConfig,
HadoopTuningConfig tuningConfig,
String dataSource,
io.druid.data.input.impl.TimestampSpec timestampSpec,
io.druid.data.input.impl.DataSpec dataSpec,
GranularitySpec granularitySpec,
Map<String,Object> pathSpec,
String workingPath,
String segmentOutputPath,
String version,
PartitionsSpec partitionsSpec,
boolean leaveIntermediate,
Boolean cleanupOnFailure,
Map<org.joda.time.DateTime,List<HadoopyShardSpec>> shardSpecs,
boolean overwriteFiles,
DataRollupSpec rollupSpec,
DbUpdaterJobSpec updaterJobSpec,
boolean ignoreInvalidRows,
Map<String,String> jobProperties,
boolean combineText,
String timestampColumn,
String timestampFormat,
List<org.joda.time.Interval> intervals,
com.metamx.common.Granularity segmentGranularity,
String partitionDimension,
Long targetPartitionSize) |
HadoopTuningConfig(String workingPath,
String version,
PartitionsSpec partitionsSpec,
Map<org.joda.time.DateTime,List<HadoopyShardSpec>> shardSpecs,
Integer rowFlushBoundary,
boolean leaveIntermediate,
Boolean cleanupOnFailure,
boolean overwriteFiles,
boolean ignoreInvalidRows,
Map<String,String> jobProperties,
boolean combineText) |
| Modifier and Type | Class and Description |
|---|---|
class |
AbstractPartitionsSpec |
class |
HashedPartitionsSpec |
class |
RandomPartitionsSpec
Deprecated.
|
class |
SingleDimensionPartitionsSpec |
Copyright © 2015. All rights reserved.