Class and Description |
---|
IndexerMetadataStorageCoordinator |
Class and Description |
---|
IndexerMetadataStorageCoordinator |
TaskLockbox
Remembers which tasks have locked which intervals.
|
TaskStorage |
Class and Description |
---|
TaskMaster
Encapsulates the indexer leadership lifecycle.
|
Class and Description |
---|
ImmutableZkWorker
A snapshot of a
ZkWorker |
RemoteTaskRunnerWorkItem |
TaskLockbox
Remembers which tasks have locked which intervals.
|
TaskQueue
Interface between task producers and the task runner.
|
TaskRunner
Interface for handing off tasks.
|
TaskRunnerFactory |
TaskRunnerWorkItem
A holder for a task and different components associated with the task
|
TaskStorage |
ZkWorker
Holds information about a worker and a listener for task status changes associated with the worker.
|
Class and Description |
---|
RemoteTaskRunner
The RemoteTaskRunner's primary responsibility is to assign tasks to worker nodes.
|
Class and Description |
---|
TaskMaster
Encapsulates the indexer leadership lifecycle.
|
TaskStorageQueryAdapter
Wraps a
TaskStorage , providing a useful collection of read-only methods. |
Class and Description |
---|
ImmutableZkWorker
A snapshot of a
ZkWorker |
Class and Description |
---|
TaskRunner
Interface for handing off tasks.
|
Class and Description |
---|
TaskRunner
Interface for handing off tasks.
|
Class and Description |
---|
ForkingTaskRunner
Runs tasks in separate processes using the "internal peon" verb.
|
Class and Description |
---|
IndexerMetadataStorageCoordinator |
Copyright © 2011–2015. All rights reserved.