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.