Uses of Interface
io.druid.indexing.overlord.WorkerTaskRunner

Packages that use WorkerTaskRunner

Package	Description
io.druid.indexing.overlord
io.druid.indexing.overlord.autoscaling

Uses of WorkerTaskRunner in io.druid.indexing.overlord

Classes in io.druid.indexing.overlord that implement WorkerTaskRunner

Modifier and Type	Class and Description
class	RemoteTaskRunner The RemoteTaskRunner's primary responsibility is to assign tasks to worker nodes.

Constructor parameters in io.druid.indexing.overlord with type arguments of type WorkerTaskRunner

Constructor and Description

RemoteTaskRunner(com.fasterxml.jackson.databind.ObjectMapper jsonMapper, RemoteTaskRunnerConfig config, IndexerZkConfig indexerZkConfig, org.apache.curator.framework.CuratorFramework cf, PathChildrenCacheFactory.Builder pathChildrenCacheFactory, com.metamx.http.client.HttpClient httpClient, com.google.common.base.Supplier<WorkerBehaviorConfig> workerConfigRef, ScheduledExecutorService cleanupExec, ResourceManagementStrategy<WorkerTaskRunner> resourceManagement)

Uses of WorkerTaskRunner in io.druid.indexing.overlord.autoscaling

Methods in io.druid.indexing.overlord.autoscaling with parameters of type WorkerTaskRunner

Modifier and Type	Method and Description
protected boolean	SimpleWorkerResourceManagementStrategy.doProvision(WorkerTaskRunner runner)
boolean	PendingTaskBasedWorkerResourceManagementStrategy.doProvision(WorkerTaskRunner runner)
boolean	PendingTaskBasedWorkerResourceManagementStrategy.doTerminate(WorkerTaskRunner runner)
Collection<ImmutableWorkerInfo>	SimpleWorkerResourceManagementStrategy.getWorkers(WorkerTaskRunner runner)
void	AbstractWorkerResourceManagementStrategy.startManagement(WorkerTaskRunner runner)