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) |
Copyright © 2011–2015. All rights reserved.