| Package | Description |
|---|---|
| io.druid.indexing.overlord | |
| io.druid.indexing.overlord.autoscaling |
| Modifier and Type | Method and Description |
|---|---|
ZkWorker |
RemoteTaskRunner.findWorkerRunningTask(String taskId) |
| Modifier and Type | Method and Description |
|---|---|
Collection<ZkWorker> |
ThreadPoolTaskRunner.getWorkers() |
Collection<ZkWorker> |
TaskRunner.getWorkers() |
Collection<ZkWorker> |
RemoteTaskRunner.getWorkers() |
Collection<ZkWorker> |
ForkingTaskRunner.getWorkers() |
| Modifier and Type | Method and Description |
|---|---|
boolean |
SimpleResourceManagementStrategy.doProvision(Collection<RemoteTaskRunnerWorkItem> pendingTasks,
Collection<ZkWorker> zkWorkers) |
boolean |
ResourceManagementStrategy.doProvision(Collection<RemoteTaskRunnerWorkItem> runningTasks,
Collection<ZkWorker> zkWorkers) |
boolean |
SimpleResourceManagementStrategy.doTerminate(Collection<RemoteTaskRunnerWorkItem> pendingTasks,
Collection<ZkWorker> zkWorkers) |
boolean |
ResourceManagementStrategy.doTerminate(Collection<RemoteTaskRunnerWorkItem> runningTasks,
Collection<ZkWorker> zkWorkers) |
Copyright © 2015. All rights reserved.