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.