RemoteTaskRunner(com.fasterxml.jackson.databind.ObjectMapper jsonMapper,
RemoteTaskRunnerConfig config,
IndexerZkConfig indexerZkConfig,
org.apache.curator.framework.CuratorFramework cf,
PathChildrenCacheFactory.Builder pathChildrenCacheFactory,
com.metamx.http.client.HttpClient httpClient,
com.google.common.base.Supplier<WorkerBehaviorConfig> workerConfigRef,
ScheduledExecutorService cleanupExec,
ResourceManagementStrategy<WorkerTaskRunner> resourceManagement) |
RemoteTaskRunnerFactory(org.apache.curator.framework.CuratorFramework curator,
RemoteTaskRunnerConfig remoteTaskRunnerConfig,
IndexerZkConfig zkPaths,
com.fasterxml.jackson.databind.ObjectMapper jsonMapper,
com.metamx.http.client.HttpClient httpClient,
com.google.common.base.Supplier<WorkerBehaviorConfig> workerConfigRef,
ScheduledExecutorFactory factory,
ResourceManagementSchedulerConfig resourceManagementSchedulerConfig,
ResourceManagementStrategy resourceManagementStrategy) |
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) |