org.apache.flink.runtime.dispatcher (Flink : 2.0-SNAPSHOT API)

Interface Summary
Interface	Description
DispatcherBootstrap	An interface containing the logic of bootstrapping the `Dispatcher` of a cluster.
DispatcherBootstrapFactory	A factory to create a `DispatcherBootstrap`.
DispatcherFactory	`Dispatcher` factory interface.
DispatcherGateway	Gateway for the Dispatcher component.
ExecutionGraphInfoStore	Interface for a `ExecutionGraphInfo` store.
HistoryServerArchivist	Writer for an `ExecutionGraphInfo`.
JobManagerMetricGroupFactory	Factory interface for `JobManagerMetricGroup`.
JobManagerRunnerFactory	Factory for a `JobManagerRunner`.
JobManagerRunnerRegistry	`JobManagerRunner` collects running jobs represented by `JobManagerRunner`.
TriggerCheckpointFunction	Wrapper interface for functions triggering checkpoints.
TriggerSavepointFunction	Wrapper interface for functions triggering savepoints.

Class Summary
Class	Description
ConfigurationNotAllowedMessage	If `DeploymentOptions.PROGRAM_CONFIG_ENABLED` is disabled, this error denotes the not allowed configuration.
DefaultJobManagerRunnerRegistry	`DefaultJobManagerRunnerRegistry` is the default implementation of the `JobManagerRunnerRegistry` interface.
Dispatcher	Base class for the Dispatcher component.
DispatcherCachedOperationsHandler	A handler for async operations triggered by the `Dispatcher` whose keys and results are cached.
DispatcherId	Fencing token of the `Dispatcher`.
DispatcherOperationCaches	Encapsulates caches for results of asynchronous operations triggered by the `Dispatcher`.
DispatcherRestEndpoint	REST endpoint for the `Dispatcher` component.
DispatcherServices	`Dispatcher` services container.
FileExecutionGraphInfoStore	Store for `ExecutionGraphInfo` instances.
MemoryExecutionGraphInfoStore	`ExecutionGraphInfoStore` implementation which stores the `ArchivedExecutionGraph` in memory.
MiniDispatcher	Mini Dispatcher which is instantiated as the dispatcher component by the `JobClusterEntrypoint`.
NoOpDispatcherBootstrap	A `DispatcherBootstrap` which submits the provided `job graphs` for execution upon dispatcher initialization.
OnMainThreadJobManagerRunnerRegistry	`OnMainThreadJobManagerRunnerRegistry` implements `JobManagerRunnerRegistry` guarding the passed `JobManagerRunnerRegistry` instance in a way that it only allows modifying methods to be executed on the component's main thread.
PartialDispatcherServices	Partial `DispatcherServices` services container which needs to be completed before being given to the `Dispatcher`.
PartialDispatcherServicesWithJobPersistenceComponents	`DispatcherFactory` services container.
StandaloneDispatcher	Dispatcher implementation which spawns a `JobMaster` for each submitted `JobGraph` within in the same process.

Enum Summary
Enum	Description
Dispatcher.ExecutionType	Enum to distinguish between initial job submission and re-submission for recovery.
JobDispatcherFactory	`DispatcherFactory` which creates a `MiniDispatcher`.
JobMasterServiceLeadershipRunnerFactory	Factory which creates a `JobMasterServiceLeadershipRunner`.
SessionDispatcherFactory	`DispatcherFactory` which creates a `StandaloneDispatcher`.
TriggerSavepointMode	Describes the context of taking a savepoint: Whether it is a savepoint for a running job or whether the job is cancelled, suspended or terminated with a savepoint.
VoidHistoryServerArchivist	No-op implementation of the `HistoryServerArchivist`.

Exception Summary
Exception	Description
DispatcherException	Base class for `Dispatcher` related exceptions.
JobCancellationFailedException	`JobCancellationFailedException` is thrown if the cancellation of a job failed.
OperationAlreadyFailedException	Exception indicating that a requested operation already exists and has failed.
UnavailableDispatcherOperationException	Exception indicating that a Dispatcher operation is temporarily unavailable.
UnknownOperationKeyException	Exception that indicates that there is no ongoing or completed savepoint for a given `JobID` and `TriggerId` pair.