Uses of Package
io.druid.indexing.overlord

Packages that use io.druid.indexing.overlord

Package	Description
io.druid.cli
io.druid.indexer.path
io.druid.indexing.common.actions
io.druid.indexing.common.tasklogs
io.druid.indexing.kafka
io.druid.indexing.kafka.supervisor
io.druid.indexing.overlord
io.druid.indexing.overlord.autoscaling
io.druid.indexing.overlord.http
io.druid.indexing.overlord.http.security
io.druid.indexing.overlord.setup
io.druid.indexing.overlord.supervisor
io.druid.indexing.worker
io.druid.indexing.worker.executor
io.druid.indexing.worker.http
io.druid.metadata
io.druid.server.http

Classes in io.druid.indexing.overlord used by io.druid.cli

Class and Description
TaskMaster Encapsulates the indexer leadership lifecycle.

Classes in io.druid.indexing.overlord used by io.druid.indexer.path

Class and Description
IndexerMetadataStorageCoordinator

Classes in io.druid.indexing.overlord used by io.druid.indexing.common.actions

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

Classes in io.druid.indexing.overlord used by io.druid.indexing.common.tasklogs

Class and Description
TaskMaster Encapsulates the indexer leadership lifecycle.

Classes in io.druid.indexing.overlord used by io.druid.indexing.kafka

Class and Description
DataSourceMetadata Commit metadata for a dataSource.

Classes in io.druid.indexing.overlord used by io.druid.indexing.kafka.supervisor

Class and Description
DataSourceMetadata Commit metadata for a dataSource.
IndexerMetadataStorageCoordinator
TaskMaster Encapsulates the indexer leadership lifecycle.
TaskStorage

Classes in io.druid.indexing.overlord used by io.druid.indexing.overlord

Class and Description
CriticalAction 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.Action
CriticalAction.Builder
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.
IndexerMetadataStorageCoordinator
LockResult This class represents the result of TaskLockbox.tryLock(TaskLockType, Task, Interval).
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
TaskStorageQueryAdapter Wraps a TaskStorage, providing a useful collection of read-only methods.
WorkerTaskRunner
ZkWorker Holds information about a worker and a listener for task status changes associated with the worker.

Classes in io.druid.indexing.overlord used by io.druid.indexing.overlord.autoscaling

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

Classes in io.druid.indexing.overlord used by io.druid.indexing.overlord.http

Class and Description
IndexerMetadataStorageAdapter
TaskMaster Encapsulates the indexer leadership lifecycle.
TaskStorageQueryAdapter Wraps a TaskStorage, providing a useful collection of read-only methods.

Classes in io.druid.indexing.overlord used by io.druid.indexing.overlord.http.security

Class and Description
TaskStorageQueryAdapter Wraps a TaskStorage, providing a useful collection of read-only methods.

Classes in io.druid.indexing.overlord used by io.druid.indexing.overlord.setup

Class and Description
ImmutableWorkerInfo A snapshot of a Worker and its current state i.e tasks assigned to that worker.

Classes in io.druid.indexing.overlord used by io.druid.indexing.overlord.supervisor

Class and Description
DataSourceMetadata Commit metadata for a dataSource.
TaskMaster Encapsulates the indexer leadership lifecycle.

Classes in io.druid.indexing.overlord used by io.druid.indexing.worker

Class and Description
TaskRunner Interface for handing off tasks.

Classes in io.druid.indexing.overlord used by io.druid.indexing.worker.executor

Class and Description
TaskRunner Interface for handing off tasks.

Classes in io.druid.indexing.overlord used by io.druid.indexing.worker.http

Class and Description
TaskRunner Interface for handing off tasks.

Classes in io.druid.indexing.overlord used by io.druid.metadata

Class and Description
DataSourceMetadata Commit metadata for a dataSource.
IndexerMetadataStorageCoordinator
SegmentPublishResult Result of an operation that attempts to publish segments.

Classes in io.druid.indexing.overlord used by io.druid.server.http

Class and Description
IndexerMetadataStorageCoordinator