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

Packages that use TaskRunner

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

Uses of TaskRunner in io.druid.indexing.overlord

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

Modifier and Type	Class and Description
class	ForkingTaskRunner Runs tasks in separate processes using the "internal peon" verb.
class	RemoteTaskRunner The RemoteTaskRunner's primary responsibility is to assign tasks to worker nodes.
class	ThreadPoolTaskRunner Runs tasks in a JVM thread using an ExecutorService.

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

Modifier and Type	Method and Description
TaskRunner	TaskRunnerFactory.build()
TaskRunner	RemoteTaskRunnerFactory.build()
TaskRunner	ForkingTaskRunnerFactory.build()

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

Modifier and Type	Method and Description
com.google.common.base.Optional<TaskRunner>	TaskMaster.getTaskRunner()

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

Constructor and Description
TaskQueue(TaskQueueConfig config, TaskStorage taskStorage, TaskRunner taskRunner, TaskActionClientFactory taskActionClientFactory, TaskLockbox taskLockbox, com.metamx.emitter.service.ServiceEmitter emitter)

Uses of TaskRunner in io.druid.indexing.worker

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

Constructor and Description
WorkerTaskMonitor(com.fasterxml.jackson.databind.ObjectMapper jsonMapper, org.apache.curator.framework.CuratorFramework cf, WorkerCuratorCoordinator workerCuratorCoordinator, TaskRunner taskRunner, WorkerConfig workerConfig)

Uses of TaskRunner in io.druid.indexing.worker.executor

Constructors in io.druid.indexing.worker.executor with parameters of type TaskRunner

Constructor and Description
ExecutorLifecycle(ExecutorLifecycleConfig config, TaskActionClientFactory taskActionClientFactory, TaskRunner taskRunner, com.fasterxml.jackson.databind.ObjectMapper jsonMapper)