| Package | Description |
|---|---|
| io.druid.indexing.overlord | |
| io.druid.indexing.worker | |
| io.druid.indexing.worker.http |
| Modifier and Type | Method and Description |
|---|---|
Worker |
ZkWorker.getWorker() |
Worker |
RemoteTaskRunnerWorkItem.getWorker() |
Worker |
ImmutableZkWorker.getWorker() |
| Modifier and Type | Method and Description |
|---|---|
boolean |
RemoteTaskRunner.isWorkerRunningTask(Worker worker,
String taskId) |
void |
ZkWorker.setWorker(Worker newWorker) |
RemoteTaskRunnerWorkItem |
RemoteTaskRunnerWorkItem.withWorker(Worker theWorker) |
| Constructor and Description |
|---|
ImmutableZkWorker(Worker worker,
int currCapacityUsed,
Set<String> availabilityGroups) |
RemoteTaskRunnerWorkItem(String taskId,
org.joda.time.DateTime createdTime,
org.joda.time.DateTime queueInsertionTime,
Worker worker) |
RemoteTaskRunnerWorkItem(String taskId,
Worker worker) |
ZkWorker(Worker worker,
org.apache.curator.framework.recipes.cache.PathChildrenCache statusCache,
com.fasterxml.jackson.databind.ObjectMapper jsonMapper) |
| Modifier and Type | Method and Description |
|---|---|
Worker |
WorkerCuratorCoordinator.getWorker() |
| Modifier and Type | Method and Description |
|---|---|
void |
WorkerCuratorCoordinator.updateWorkerAnnouncement(Worker newWorker) |
| Constructor and Description |
|---|
WorkerCuratorCoordinator(com.fasterxml.jackson.databind.ObjectMapper jsonMapper,
IndexerZkConfig indexerZkConfig,
RemoteTaskRunnerConfig config,
org.apache.curator.framework.CuratorFramework curatorFramework,
Worker worker) |
| Constructor and Description |
|---|
WorkerResource(Worker worker,
WorkerCuratorCoordinator curatorCoordinator,
ForkingTaskRunner taskRunner) |
Copyright © 2011–2015. All rights reserved.