Package | Description |
---|---|
io.druid.indexer.hadoop | |
io.druid.segment.indexing | |
io.druid.segment.realtime.firehose | |
io.druid.segment.transform |
Modifier and Type | Method and Description |
---|---|
TransformSpec |
DatasourceIngestionSpec.getTransformSpec() |
Modifier and Type | Method and Description |
---|---|
DatasourceIngestionSpec |
DatasourceIngestionSpec.withTransformSpec(TransformSpec transformSpec) |
Constructor and Description |
---|
DatasourceIngestionSpec(String dataSource,
org.joda.time.Interval interval,
List<org.joda.time.Interval> intervals,
List<DataSegment> segments,
DimFilter filter,
List<String> dimensions,
List<String> metrics,
boolean ignoreWhenNoSegments,
TransformSpec transformSpec) |
Modifier and Type | Method and Description |
---|---|
TransformSpec |
DataSchema.getTransformSpec() |
Modifier and Type | Method and Description |
---|---|
DataSchema |
DataSchema.withTransformSpec(TransformSpec transformSpec) |
Constructor and Description |
---|
DataSchema(String dataSource,
Map<String,Object> parser,
AggregatorFactory[] aggregators,
GranularitySpec granularitySpec,
TransformSpec transformSpec,
com.fasterxml.jackson.databind.ObjectMapper jsonMapper) |
Constructor and Description |
---|
IngestSegmentFirehose(List<WindowedStorageAdapter> adapters,
TransformSpec transformSpec,
List<String> dims,
List<String> metrics,
DimFilter dimFilter) |
Modifier and Type | Field and Description |
---|---|
static TransformSpec |
TransformSpec.NONE |
Modifier and Type | Method and Description |
---|---|
static <T> TransformSpec |
TransformSpec.fromInputRowParser(InputRowParser<T> parser) |
TransformSpec |
TransformingStringInputRowParser.getTransformSpec() |
TransformSpec |
TransformingInputRowParser.getTransformSpec() |
Constructor and Description |
---|
TransformingInputRowParser(InputRowParser<T> parser,
TransformSpec transformSpec) |
TransformingStringInputRowParser(ParseSpec parseSpec,
String encoding,
TransformSpec transformSpec) |
Copyright © 2011–2018. All rights reserved.