Uses of Class
io.druid.indexing.worker.Worker

Packages that use Worker

Package	Description
io.druid.indexing.overlord
io.druid.indexing.worker
io.druid.indexing.worker.http

Uses of Worker in io.druid.indexing.overlord

Methods in io.druid.indexing.overlord that return Worker

Modifier and Type	Method and Description
Worker	ZkWorker.getWorker()
Worker	RemoteTaskRunnerWorkItem.getWorker()
Worker	ImmutableWorkerInfo.getWorker()

Methods in io.druid.indexing.overlord that return types with arguments of type Worker

Modifier and Type	Method and Description
Collection<Worker>	WorkerTaskRunner.getLazyWorkers() Return a list of workers who can be reaped by autoscaling
Collection<Worker>	RemoteTaskRunner.getLazyWorkers()
static Collection<Worker>	RemoteTaskRunner.getWorkerFromZK(Collection<ZkWorker> workers)
Collection<Worker>	WorkerTaskRunner.markWorkersLazy(com.google.common.base.Predicate<ImmutableWorkerInfo> isLazyWorker, int maxWorkers) Check which workers can be marked as lazy
Collection<Worker>	RemoteTaskRunner.markWorkersLazy(com.google.common.base.Predicate<ImmutableWorkerInfo> isLazyWorker, int maxWorkers)

Methods in io.druid.indexing.overlord with parameters of type Worker

Modifier and Type	Method and Description
protected List<String>	RemoteTaskRunner.getAssignedTasks(Worker worker)
boolean	RemoteTaskRunner.isWorkerRunningTask(Worker worker, String taskId)
void	ZkWorker.setWorker(Worker newWorker)
RemoteTaskRunnerWorkItem	RemoteTaskRunnerWorkItem.withWorker(Worker theWorker, TaskLocation location)

Constructors in io.druid.indexing.overlord with parameters of type Worker

Constructor and Description
ImmutableWorkerInfo(Worker worker, int currCapacityUsed, Set<String> availabilityGroups, Collection<String> runningTasks, org.joda.time.DateTime lastCompletedTaskTime)
RemoteTaskRunnerWorkItem(String taskId, org.joda.time.DateTime createdTime, org.joda.time.DateTime queueInsertionTime, Worker worker, TaskLocation location)
RemoteTaskRunnerWorkItem(String taskId, Worker worker, TaskLocation location)
ZkWorker(Worker worker, org.apache.curator.framework.recipes.cache.PathChildrenCache statusCache, com.fasterxml.jackson.databind.ObjectMapper jsonMapper)

Uses of Worker in io.druid.indexing.worker

Methods in io.druid.indexing.worker that return Worker

Modifier and Type	Method and Description
Worker	WorkerCuratorCoordinator.getWorker()

Methods in io.druid.indexing.worker with parameters of type Worker

Modifier and Type	Method and Description
void	WorkerCuratorCoordinator.updateWorkerAnnouncement(Worker newWorker)

Constructors in io.druid.indexing.worker with parameters of type Worker

Constructor and Description
WorkerCuratorCoordinator(com.fasterxml.jackson.databind.ObjectMapper jsonMapper, IndexerZkConfig indexerZkConfig, RemoteTaskRunnerConfig config, org.apache.curator.framework.CuratorFramework curatorFramework, Worker worker)

Uses of Worker in io.druid.indexing.worker.http

Constructors in io.druid.indexing.worker.http with parameters of type Worker

Constructor and Description
WorkerResource(Worker worker, WorkerCuratorCoordinator curatorCoordinator, TaskRunner taskRunner)