Class and Description |
---|
TaskMaster
Encapsulates the indexer leadership lifecycle.
|
Class and Description |
---|
IndexerMetadataStorageCoordinator |
Class and Description |
---|
DataSourceMetadata
Commit metadata for a dataSource.
|
IndexerMetadataStorageCoordinator |
SegmentPublishResult
Result of an operation that attempts to publish segments.
|
TaskLockbox
Remembers which activeTasks have locked which intervals.
|
TaskStorage |
Class and Description |
---|
TaskMaster
Encapsulates the indexer leadership lifecycle.
|
Class and Description |
---|
DataSourceMetadata
Commit metadata for a dataSource.
|
Class and Description |
---|
DataSourceMetadata
Commit metadata for a dataSource.
|
IndexerMetadataStorageCoordinator |
TaskMaster
Encapsulates the indexer leadership lifecycle.
|
TaskStorage |
Class and Description |
---|
DataSourceMetadata
Commit metadata for a dataSource.
|
ForkingTaskRunner
Runs tasks in separate processes using the "internal peon" verb.
|
ImmutableWorkerInfo
A snapshot of a Worker and its current state i.e tasks assigned to that worker.
|
RemoteTaskRunner
The RemoteTaskRunner's primary responsibility is to assign tasks to worker nodes.
|
RemoteTaskRunnerWorkItem |
SegmentPublishResult
Result of an operation that attempts to publish segments.
|
TaskLockbox
Remembers which activeTasks have locked which intervals.
|
TaskQueue
Interface between task producers and the task runner.
|
TaskRunner
Interface for handing off tasks.
|
TaskRunnerFactory |
TaskRunnerListener
Listener to be registered with
TaskRunner.registerListener(TaskRunnerListener, Executor) . |
TaskRunnerWorkItem
A holder for a task and different components associated with the task
|
TaskStorage |
WorkerTaskRunner |
ZkWorker
Holds information about a worker and a listener for task status changes associated with the worker.
|
Class and Description |
---|
ImmutableWorkerInfo
A snapshot of a Worker and its current state i.e tasks assigned to that worker.
|
TaskRunner
Interface for handing off tasks.
|
WorkerTaskRunner |
Class and Description |
---|
TaskMaster
Encapsulates the indexer leadership lifecycle.
|
TaskStorageQueryAdapter
Wraps a
TaskStorage , providing a useful collection of read-only methods. |
Class and Description |
---|
TaskStorageQueryAdapter
Wraps a
TaskStorage , providing a useful collection of read-only methods. |
Class and Description |
---|
ImmutableWorkerInfo
A snapshot of a Worker and its current state i.e tasks assigned to that worker.
|
Class and Description |
---|
DataSourceMetadata
Commit metadata for a dataSource.
|
TaskMaster
Encapsulates the indexer leadership lifecycle.
|
Class and Description |
---|
TaskRunner
Interface for handing off tasks.
|
Class and Description |
---|
TaskRunner
Interface for handing off tasks.
|
Class and Description |
---|
TaskRunner
Interface for handing off tasks.
|
Class and Description |
---|
DataSourceMetadata
Commit metadata for a dataSource.
|
IndexerMetadataStorageCoordinator |
SegmentPublishResult
Result of an operation that attempts to publish segments.
|
Class and Description |
---|
IndexerMetadataStorageCoordinator |
Copyright © 2011–2017. All rights reserved.