| Package | Description |
|---|---|
| io.druid.indexer.path | |
| io.druid.indexing.common.actions | |
| io.druid.indexing.kafka.supervisor | |
| io.druid.metadata | |
| io.druid.server.http |
| Constructor and Description |
|---|
MetadataStoreBasedUsedSegmentLister(IndexerMetadataStorageCoordinator indexerMetadataStorageCoordinator) |
| Modifier and Type | Method and Description |
|---|---|
IndexerMetadataStorageCoordinator |
TaskActionToolbox.getIndexerMetadataStorageCoordinator() |
| Constructor and Description |
|---|
TaskActionToolbox(TaskLockbox taskLockbox,
IndexerMetadataStorageCoordinator indexerMetadataStorageCoordinator,
com.metamx.emitter.service.ServiceEmitter emitter,
SupervisorManager supervisorManager) |
| Constructor and Description |
|---|
KafkaSupervisor(TaskStorage taskStorage,
TaskMaster taskMaster,
IndexerMetadataStorageCoordinator indexerMetadataStorageCoordinator,
KafkaIndexTaskClientFactory taskClientFactory,
com.fasterxml.jackson.databind.ObjectMapper mapper,
KafkaSupervisorSpec spec) |
KafkaSupervisorSpec(DataSchema dataSchema,
KafkaSupervisorTuningConfig tuningConfig,
KafkaSupervisorIOConfig ioConfig,
Map<String,Object> context,
TaskStorage taskStorage,
TaskMaster taskMaster,
IndexerMetadataStorageCoordinator indexerMetadataStorageCoordinator,
KafkaIndexTaskClientFactory kafkaIndexTaskClientFactory,
com.fasterxml.jackson.databind.ObjectMapper mapper) |
| Modifier and Type | Class and Description |
|---|---|
class |
IndexerSQLMetadataStorageCoordinator |
| Constructor and Description |
|---|
MetadataResource(MetadataSegmentManager metadataSegmentManager,
IndexerMetadataStorageCoordinator metadataStorageCoordinator,
AuthConfig authConfig) |
Copyright © 2011–2017. All rights reserved.