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.