| 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,
com.metamx.emitter.service.ServiceEmitter emitter) |
| Modifier and Type | Class and Description |
|---|---|
class |
NoopResourceManagementStrategy<T extends TaskRunner> |
interface |
ResourceManagementStrategy<T extends TaskRunner>
The ResourceManagementStrategy decides if worker nodes should be provisioned or determined
based on the available tasks in the system and the state of the workers in the system.
|
| 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–2017. All rights reserved.