Package | Description |
---|---|
io.druid.indexing.common.actions | |
io.druid.indexing.overlord |
Modifier and Type | Method and Description |
---|---|
TaskLockbox |
TaskActionToolbox.getTaskLockbox() |
Constructor and Description |
---|
TaskActionToolbox(TaskLockbox taskLockbox,
IndexerMetadataStorageCoordinator indexerMetadataStorageCoordinator,
com.metamx.emitter.service.ServiceEmitter emitter) |
Constructor and Description |
---|
TaskMaster(TaskQueueConfig taskQueueConfig,
TaskLockbox taskLockbox,
TaskStorage taskStorage,
TaskActionClientFactory taskActionClientFactory,
DruidNode node,
IndexerZkConfig zkPaths,
TaskRunnerFactory runnerFactory,
ResourceManagementSchedulerFactory managementSchedulerFactory,
org.apache.curator.framework.CuratorFramework curator,
ServiceAnnouncer serviceAnnouncer,
com.metamx.emitter.service.ServiceEmitter emitter) |
TaskQueue(TaskQueueConfig config,
TaskStorage taskStorage,
TaskRunner taskRunner,
TaskActionClientFactory taskActionClientFactory,
TaskLockbox taskLockbox,
com.metamx.emitter.service.ServiceEmitter emitter) |
Copyright © 2011–2015. All rights reserved.