| Package | Description |
|---|---|
| io.druid.indexing.kafka | |
| io.druid.indexing.kafka.supervisor |
| Modifier and Type | Method and Description |
|---|---|
KafkaTuningConfig |
KafkaIndexTask.getTuningConfig() |
KafkaTuningConfig |
KafkaTuningConfig.withBasePersistDirectory(File dir) |
| Constructor and Description |
|---|
KafkaIndexTask(String id,
TaskResource taskResource,
DataSchema dataSchema,
KafkaTuningConfig tuningConfig,
KafkaIOConfig ioConfig,
Map<String,Object> context,
ChatHandlerProvider chatHandlerProvider) |
| Modifier and Type | Method and Description |
|---|---|
KafkaTuningConfig |
KafkaSupervisorSpec.getTuningConfig() |
| Constructor and Description |
|---|
KafkaSupervisorSpec(DataSchema dataSchema,
KafkaTuningConfig tuningConfig,
KafkaSupervisorIOConfig ioConfig,
TaskStorage taskStorage,
TaskMaster taskMaster,
IndexerMetadataStorageCoordinator indexerMetadataStorageCoordinator,
KafkaIndexTaskClientFactory kafkaIndexTaskClientFactory,
com.fasterxml.jackson.databind.ObjectMapper mapper) |
Copyright © 2011–2016. All rights reserved.