| Package | Description | 
|---|---|
| io.druid.indexing.overlord | |
| io.druid.indexing.overlord.setup | 
| Modifier and Type | Method and Description | 
|---|---|
ImmutableZkWorker | 
ZkWorker.toImmutable()  | 
| 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)  | 
| 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)  | 
Copyright © 2015. All rights reserved.