| Package | Description |
|---|---|
| io.druid.indexer | |
| io.druid.indexing.common.task |
| Modifier and Type | Method and Description |
|---|---|
HadoopIngestionSpec |
HadoopDruidIndexerConfig.getSchema() |
static HadoopIngestionSpec |
HadoopIngestionSpec.updateSegmentListIfDatasourcePathSpecIsUsed(HadoopIngestionSpec spec,
com.fasterxml.jackson.databind.ObjectMapper jsonMapper,
UsedSegmentLister segmentLister) |
HadoopIngestionSpec |
HadoopIngestionSpec.withDataSchema(DataSchema schema) |
HadoopIngestionSpec |
HadoopIngestionSpec.withIOConfig(HadoopIOConfig config) |
HadoopIngestionSpec |
HadoopIngestionSpec.withTuningConfig(HadoopTuningConfig config) |
| Modifier and Type | Method and Description |
|---|---|
static HadoopDruidIndexerConfig |
HadoopDruidIndexerConfig.fromSpec(HadoopIngestionSpec spec) |
static HadoopIngestionSpec |
HadoopIngestionSpec.updateSegmentListIfDatasourcePathSpecIsUsed(HadoopIngestionSpec spec,
com.fasterxml.jackson.databind.ObjectMapper jsonMapper,
UsedSegmentLister segmentLister) |
| Constructor and Description |
|---|
HadoopDruidIndexerConfig(HadoopIngestionSpec spec) |
| Modifier and Type | Method and Description |
|---|---|
HadoopIngestionSpec |
HadoopIndexTask.getSpec() |
| Constructor and Description |
|---|
HadoopIndexTask(String id,
HadoopIngestionSpec spec,
String hadoopCoordinates,
List<String> hadoopDependencyCoordinates,
String classpathPrefix,
com.fasterxml.jackson.databind.ObjectMapper jsonMapper,
Map<String,Object> context) |
Copyright © 2011–2017. All rights reserved.