Package | Description |
---|---|
io.druid.indexer | |
io.druid.indexing.common.task | |
io.druid.segment.indexing | |
io.druid.segment.indexing.granularity |
Modifier and Type | Method and Description |
---|---|
GranularitySpec |
HadoopDruidIndexerConfig.getGranularitySpec() |
Modifier and Type | Method and Description |
---|---|
void |
HadoopDruidIndexerConfig.setGranularitySpec(GranularitySpec granularitySpec) |
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) |
Constructor and Description |
---|
IndexTask(String id,
IndexTask.IndexIngestionSpec ingestionSpec,
IndexTask.IndexIngestionSpec schema,
String dataSource,
GranularitySpec granularitySpec,
AggregatorFactory[] aggregators,
QueryGranularity indexGranularity,
int targetPartitionSize,
io.druid.data.input.FirehoseFactory firehoseFactory,
int rowFlushBoundary,
com.fasterxml.jackson.databind.ObjectMapper jsonMapper) |
Modifier and Type | Method and Description |
---|---|
GranularitySpec |
DataSchema.getGranularitySpec() |
Modifier and Type | Method and Description |
---|---|
DataSchema |
DataSchema.withGranularitySpec(GranularitySpec granularitySpec) |
Constructor and Description |
---|
DataSchema(String dataSource,
io.druid.data.input.impl.InputRowParser parser,
AggregatorFactory[] aggregators,
GranularitySpec granularitySpec) |
Modifier and Type | Class and Description |
---|---|
class |
ArbitraryGranularitySpec |
class |
UniformGranularitySpec |
Modifier and Type | Method and Description |
---|---|
GranularitySpec |
UniformGranularitySpec.withQueryGranularity(QueryGranularity queryGranularity) |
GranularitySpec |
GranularitySpec.withQueryGranularity(QueryGranularity queryGranularity)
Deprecated.
|
GranularitySpec |
ArbitraryGranularitySpec.withQueryGranularity(QueryGranularity queryGranularity) |
Copyright © 2015. All rights reserved.