| Package | Description | 
|---|---|
| io.druid.indexing.overlord | |
| io.druid.indexing.overlord.autoscaling | |
| io.druid.indexing.worker | |
| io.druid.indexing.worker.executor | |
| io.druid.indexing.worker.http | 
| Modifier and Type | Interface and Description | 
|---|---|
interface  | 
TaskRunnerFactory<T extends TaskRunner>  | 
| Modifier and Type | Interface and Description | 
|---|---|
interface  | 
WorkerTaskRunner  | 
| 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. 
 | 
| Modifier and Type | Method and Description | 
|---|---|
com.google.common.base.Optional<TaskRunner> | 
TaskMaster.getTaskRunner()  | 
| Constructor and Description | 
|---|
TaskQueue(TaskQueueConfig config,
         TaskStorage taskStorage,
         TaskRunner taskRunner,
         TaskActionClientFactory taskActionClientFactory,
         TaskLockbox taskLockbox,
         ServiceEmitter emitter)  | 
| Modifier and Type | Class and Description | 
|---|---|
class  | 
NoopProvisioningStrategy<T extends TaskRunner>  | 
interface  | 
ProvisioningStrategy<T extends TaskRunner>
In general, the resource management is tied to the runner. 
 | 
| Constructor and Description | 
|---|
WorkerTaskMonitor(com.fasterxml.jackson.databind.ObjectMapper jsonMapper,
                 org.apache.curator.framework.CuratorFramework cf,
                 WorkerCuratorCoordinator workerCuratorCoordinator,
                 TaskRunner taskRunner)  | 
| Constructor and Description | 
|---|
ExecutorLifecycle(ExecutorLifecycleConfig taskExecutorConfig,
                 TaskConfig taskConfig,
                 TaskActionClientFactory taskActionClientFactory,
                 TaskRunner taskRunner,
                 com.fasterxml.jackson.databind.ObjectMapper jsonMapper)  | 
| Constructor and Description | 
|---|
WorkerResource(Worker worker,
              WorkerCuratorCoordinator curatorCoordinator,
              TaskRunner taskRunner)  | 
Copyright © 2011–2018. All rights reserved.