| 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.