| Package | Description | 
|---|---|
| io.druid.cli | |
| io.druid.indexing.common.tasklogs | |
| io.druid.indexing.kafka.supervisor | |
| io.druid.indexing.overlord.http | |
| io.druid.indexing.overlord.supervisor | 
| Constructor and Description | 
|---|
CoordinatorOverlordRedirectInfo(TaskMaster taskMaster,
                               DruidCoordinator druidCoordinator)  | 
| Constructor and Description | 
|---|
TaskRunnerTaskLogStreamer(TaskMaster taskMaster)  | 
| 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,
                   ServiceEmitter emitter,
                   DruidMonitorSchedulerConfig monitorSchedulerConfig)  | 
| Constructor and Description | 
|---|
OverlordRedirectInfo(TaskMaster taskMaster)  | 
OverlordResource(TaskMaster taskMaster,
                TaskStorageQueryAdapter taskStorageQueryAdapter,
                IndexerMetadataStorageAdapter indexerMetadataStorageAdapter,
                TaskLogStreamer taskLogStreamer,
                JacksonConfigManager configManager,
                AuditManager auditManager,
                AuthorizerMapper authorizerMapper)  | 
| Constructor and Description | 
|---|
SupervisorResource(TaskMaster taskMaster,
                  AuthConfig authConfig,
                  AuthorizerMapper authorizerMapper)  | 
Copyright © 2011–2018. All rights reserved.