Package org.apache.flink.runtime.jobmanager

Interface Summary

Interface	Description
JobGraphStore	JobGraph instances for recovery.
JobGraphStore.JobGraphListener	A listener for JobGraph instances.
JobGraphStoreUtil	JobGraphStore utility interfaces.
JobGraphStoreWatcher	A watcher on JobGraphStore.
JobGraphWriter	Allows to store and remove job graphs.
JobPersistenceComponentFactory	Factory for components that are responsible for persisting a job for recovery.
OnCompletionActions	Interface for completion actions once a Flink job has reached a terminal state.

Class Summary

Class	Description
DefaultJobGraphStore<R extends ResourceVersion<R>>	Default implementation for JobGraphStore.
HaServicesJobPersistenceComponentFactory	JobPersistenceComponentFactory implementation which creates a JobGraphStore using the provided HighAvailabilityServices.
JobManagerProcessSpec	Describe the specifics of different resource dimensions of the JobManager process.
JobManagerProcessUtils	JobManager utils to calculate JobManagerProcessSpec and JVM args.
StandaloneJobGraphStore	JobGraph instances for JobManagers running in HighAvailabilityMode.NONE.
ZooKeeperJobGraphStoreWatcher	JobGraphStoreWatcher implementation for ZooKeeper.

Enum Summary

Enum	Description
HighAvailabilityMode	High availability mode for Flink's cluster execution.
NoOpJobGraphStoreWatcher	Singleton JobGraphStoreWatcher empty implementation.
ThrowingJobGraphWriter	JobGraphWriter implementation which does not allow to store JobGraph.
ZooKeeperJobGraphStoreUtil	Singleton JobGraphStoreUtil implementation for ZooKeeper.

Exception Summary

Exception	Description
PartitionProducerDisposedException	Exception returned to a TaskManager on JobMaster requesting partition state, if the producer of a partition has been disposed.