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.