Package io.druid.indexing.overlord

Interface Summary

Interface	Description
IndexerMetadataStorageCoordinator
TaskRunner	Interface for handing off tasks.
TaskRunnerFactory
TaskStorage

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.
ImmutableZkWorker	A snapshot of a ZkWorker
MetadataTaskStorage
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.