| Interface | Description |
|---|---|
| TaskRunner |
Interface for handing off tasks.
|
| TaskRunnerFactory | |
| TaskStorage |
| Class | Description |
|---|---|
| DbTaskStorage | |
| ForkingTaskRunner |
Runs tasks in separate processes using the "internal peon" verb.
|
| ForkingTaskRunnerFactory | |
| HeapMemoryTaskStorage |
Implements an in-heap TaskStorage facility, with no persistence across restarts.
|
| ImmutableZkWorker |
A snapshot of a
ZkWorker |
| IndexerDBCoordinator | |
| PortFinder | |
| RemoteTaskRunner |
The RemoteTaskRunner's primary responsibility is to assign tasks to worker nodes.
|
| RemoteTaskRunnerFactory | |
| RemoteTaskRunnerWorkItem | |
| RemoteTaskRunnerWorkQueue | |
| TaskLockbox |
Remembers which tasks have locked which intervals.
|
| TaskMaster |
Encapsulates the indexer leadership lifecycle.
|
| TaskQueue |
Interface between task producers and the task runner.
|
| TaskRunnerWorkItem |
A holder for a task and different components associated with the task
|
| TaskStorageQueryAdapter |
Wraps a
TaskStorage, providing a useful collection of read-only methods. |
| ThreadPoolTaskRunner |
Runs tasks in a JVM thread using an ExecutorService.
|
| ZkWorker |
Holds information about a worker and a listener for task status changes associated with the worker.
|
| Exception | Description |
|---|---|
| TaskExistsException |
Copyright © 2014. All rights reserved.