| 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.