| Package | Description |
|---|---|
| io.druid.indexing.common.actions | |
| io.druid.indexing.overlord |
| Modifier and Type | Method and Description |
|---|---|
SupervisorManager |
TaskActionToolbox.getSupervisorManager() |
| Constructor and Description |
|---|
TaskActionToolbox(TaskLockbox taskLockbox,
IndexerMetadataStorageCoordinator indexerMetadataStorageCoordinator,
com.metamx.emitter.service.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,
IndexerZkConfig zkPaths,
TaskRunnerFactory runnerFactory,
org.apache.curator.framework.CuratorFramework curator,
ServiceAnnouncer serviceAnnouncer,
CoordinatorOverlordServiceConfig coordinatorOverlordServiceConfig,
com.metamx.emitter.service.ServiceEmitter emitter,
SupervisorManager supervisorManager,
OverlordHelperManager overlordHelperManager) |
Copyright © 2011–2017. All rights reserved.