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.