| Package | Description | 
|---|---|
| io.druid.indexing.overlord | |
| io.druid.indexing.overlord.setup | |
| io.druid.indexing.worker | 
| Constructor and Description | 
|---|
RemoteTaskRunner(com.fasterxml.jackson.databind.ObjectMapper jsonMapper,
                RemoteTaskRunnerConfig config,
                IndexerZkConfig indexerZkConfig,
                org.apache.curator.framework.CuratorFramework cf,
                PathChildrenCacheFactory pathChildrenCacheFactory,
                com.metamx.http.client.HttpClient httpClient,
                com.google.common.base.Supplier<WorkerBehaviorConfig> workerConfigRef)  | 
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)  | 
| Modifier and Type | Method and Description | 
|---|---|
com.google.common.base.Optional<ImmutableZkWorker> | 
WorkerSelectStrategy.findWorkerForTask(RemoteTaskRunnerConfig config,
                 com.google.common.collect.ImmutableMap<String,ImmutableZkWorker> zkWorkers,
                 Task task)
Customizable logic for selecting a worker to run a task. 
 | 
com.google.common.base.Optional<ImmutableZkWorker> | 
FillCapacityWorkerSelectStrategy.findWorkerForTask(RemoteTaskRunnerConfig config,
                 com.google.common.collect.ImmutableMap<String,ImmutableZkWorker> zkWorkers,
                 Task task)  | 
com.google.common.base.Optional<ImmutableZkWorker> | 
FillCapacityWithAffinityWorkerSelectStrategy.findWorkerForTask(RemoteTaskRunnerConfig config,
                 com.google.common.collect.ImmutableMap<String,ImmutableZkWorker> zkWorkers,
                 Task task)  | 
com.google.common.base.Optional<ImmutableZkWorker> | 
EqualDistributionWorkerSelectStrategy.findWorkerForTask(RemoteTaskRunnerConfig config,
                 com.google.common.collect.ImmutableMap<String,ImmutableZkWorker> zkWorkers,
                 Task task)  | 
| Constructor and Description | 
|---|
WorkerCuratorCoordinator(com.fasterxml.jackson.databind.ObjectMapper jsonMapper,
                        IndexerZkConfig indexerZkConfig,
                        RemoteTaskRunnerConfig config,
                        org.apache.curator.framework.CuratorFramework curatorFramework,
                        Worker worker)  | 
Copyright © 2015. All rights reserved.