| 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 © 2015. All rights reserved.