Package | Description |
---|---|
io.druid.indexing.common.actions | |
io.druid.indexing.overlord | |
io.druid.indexing.overlord.http.security |
Modifier and Type | Method and Description |
---|---|
SupervisorManager |
TaskActionToolbox.getSupervisorManager() |
Constructor and Description |
---|
TaskActionToolbox(TaskLockbox taskLockbox,
IndexerMetadataStorageCoordinator indexerMetadataStorageCoordinator,
ServiceEmitter emitter,
SupervisorManager supervisorManager) |
Modifier and Type | Method and Description |
---|---|
com.google.common.base.Optional<SupervisorManager> |
TaskMaster.getSupervisorManager() |
Constructor and Description |
---|
TaskMaster(TaskQueueConfig taskQueueConfig,
TaskLockbox taskLockbox,
TaskStorage taskStorage,
TaskActionClientFactory taskActionClientFactory,
DruidNode selfNode,
TaskRunnerFactory runnerFactory,
ServiceAnnouncer serviceAnnouncer,
CoordinatorOverlordServiceConfig coordinatorOverlordServiceConfig,
ServiceEmitter emitter,
SupervisorManager supervisorManager,
OverlordHelperManager overlordHelperManager,
DruidLeaderSelector overlordLeaderSelector) |
Constructor and Description |
---|
SupervisorResourceFilter(AuthorizerMapper authorizerMapper,
SupervisorManager supervisorManager) |
Copyright © 2011–2018. All rights reserved.