Package org.apache.flink.runtime.dispatcher

Interface Summary

Interface	Description
ArchivedExecutionGraphStore	Interface for a ArchivedExecutionGraph store.
Dispatcher.JobManagerRunnerFactory	Factory for a JobManagerRunner.
DispatcherGateway	Gateway for the Dispatcher component.
HistoryServerArchivist	Writer for an AccessExecutionGraph.

Class Summary

Class	Description
Dispatcher	Base class for the Dispatcher component.
DispatcherId	Fencing token of the Dispatcher.
DispatcherRestEndpoint	REST endpoint for the Dispatcher component.
FileArchivedExecutionGraphStore	Store for ArchivedExecutionGraph.
MemoryArchivedExecutionGraphStore	ArchivedExecutionGraphStore implementation which stores the ArchivedExecutionGraph in memory.
MiniDispatcher	Mini Dispatcher which is instantiated as the dispatcher component by the JobClusterEntrypoint.
SingleJobSubmittedJobGraphStore	SubmittedJobGraphStore implementation for a single job.
StandaloneDispatcher	Dispatcher implementation which spawns a JobMaster for each submitted JobGraph within in the same process.

Enum Summary

Enum	Description
Dispatcher.DefaultJobManagerRunnerFactory	Singleton default factory for JobManagerRunner.
VoidHistoryServerArchivist	No-op implementation of the HistoryServerArchivist.

Exception Summary

Exception	Description
DispatcherException	Base class for Dispatcher related exceptions.