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, HttpClient httpClient, com.google.common.base.Supplier<WorkerBehaviorConfig> workerConfigRef, ProvisioningStrategy<WorkerTaskRunner> provisioningStrategy)

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
Provisioner	SimpleWorkerProvisioningStrategy.makeProvisioner(WorkerTaskRunner runner)
Provisioner	PendingTaskBasedWorkerProvisioningStrategy.makeProvisioner(WorkerTaskRunner runner)
protected abstract Provisioner	AbstractWorkerProvisioningStrategy.makeProvisioner(WorkerTaskRunner runner)
ProvisioningService	AbstractWorkerProvisioningStrategy.makeProvisioningService(WorkerTaskRunner runner)