Package io.druid.indexing.overlord

Interface Summary

Interface	Description
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
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.
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.