Package org.apache.flink.runtime.jobmaster

Interface Summary

Interface	Description
JobManagerGateway	Public JobManager gateway.
JobMasterGateway	JobMaster rpc gateway interface.
KvStateLocationOracle	Oracle for KvStateLocation in the cluster.
KvStateRegistryGateway	Gateway to report key-value state registration and deregistrations.
LogicalSlot	A logical slot represents a resource on a TaskManager into which a single task can be deployed.
LogicalSlot.Payload	Payload for a logical slot.
SlotContext	Interface for the context of a LogicalSlot.
SlotOwner	Interface for components that hold slots and to which slots get released / recycled.

Class Summary

Class	Description
JMTMRegistrationSuccess	Message indicating a successful JobMaster and TaskExecutor registration.
JobManagerRunner	The runner for the job manager.
JobManagerSharedServices	Utility class which holds all auxiliary shared services used by the JobMaster.
JobMaster	JobMaster implementation.
JobMasterConfiguration	Configuration for the JobMaster.
JobMasterId	The JobMaster fencing token.
JobMasterRegistrationSuccess	Base class for responses from the ResourceManager to a registration attempt by a JobMaster.
JobResult	Similar to JobExecutionResult but with an optional SerializedThrowable when the job failed.
JobResult.Builder	Builder for JobResult.
MiniDispatcherRestEndpoint	REST endpoint for the JobClusterEntrypoint.
ResourceManagerAddress	Current address and fencing token of the leading ResourceManager.
RpcTaskManagerGateway	Implementation of the TaskManagerGateway for Flink's RPC system.
SerializedInputSplit
SlotRequestId	This ID identifies the request for a logical slot from the Execution to the SlotPool oe SlotProvider.

Enum Summary

Enum	Description
RescalingBehaviour	Definition of the rescaling behaviour.

Exception Summary

Exception	Description
ExecutionGraphException	Exceptions thrown by operations on the ExecutionGraph by the JobMaster.
JobManagerException	Base exception thrown by the JobMaster.
JobMasterException	Base class for JobMaster related exceptions.
JobNotFinishedException	Exception indicating that a Flink job has not been finished.