Package io.druid.indexing.overlord

Interface Summary

Interface	Description
CriticalAction.Action<T>
DataSourceMetadata	Commit metadata for a dataSource.
IndexerMetadataStorageCoordinator
TaskRunner	Interface for handing off tasks.
TaskRunnerFactory<T extends TaskRunner>
TaskRunnerListener	Listener to be registered with TaskRunner.registerListener(TaskRunnerListener, Executor).
TaskStorage
WorkerTaskRunner

Class Summary

Class	Description
CriticalAction<T>	This class represents a critical action must be done while the task's lock is guaranteed to not be revoked in the middle of the action.
CriticalAction.Builder<T>
ForkingTaskRunner	Runs tasks in separate processes using the "internal peon" verb.
ForkingTaskRunnerFactory
HeapMemoryTaskStorage	Implements an in-heap TaskStorage facility, with no persistence across restarts.
ImmutableWorkerInfo	A snapshot of a Worker and its current state i.e tasks assigned to that worker.
IndexerMetadataStorageAdapter
LockResult	This class represents the result of TaskLockbox.tryLock(TaskLockType, Task, Interval).
MetadataTaskStorage
ObjectMetadata
PortFinder
RemoteTaskRunner	The RemoteTaskRunner's primary responsibility is to assign tasks to worker nodes.
RemoteTaskRunnerFactory
RemoteTaskRunnerWorkItem
RemoteTaskRunnerWorkQueue
SegmentPublishResult	Result of an operation that attempts to publish segments.
TaskLockbox	Remembers which activeTasks have locked which intervals.
TaskMaster	Encapsulates the indexer leadership lifecycle.
TaskQueue	Interface between task producers and the task runner.
TaskRunnerUtils
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.