Package org.apache.flink.core.execution

Interface Summary

Interface	Description
CacheSupportedPipelineExecutor	The pipeline executor that support caching intermediate dataset.
JobClient	A client that is scoped to a specific job.
JobExecutionStatusEvent	Job execution status event.
JobListener	A listener that is notified on specific job status changed, which should be firstly registered by #registerJobListener of execution environments.
JobStatusChangedEvent	Basic job status event.
JobStatusChangedListener	When job is created or its status is changed, Flink will generate job event and notify job status changed listener.
JobStatusChangedListenerFactory	Factory for job status changed listener.
JobStatusChangedListenerFactory.Context
JobStatusHook	Hooks on job status changing.
PipelineExecutor	The entity responsible for executing a Pipeline, i.e. a user job.
PipelineExecutorFactory	A factory for selecting and instantiating the adequate PipelineExecutor based on a provided Configuration.
PipelineExecutorServiceLoader	An interface to be implemented by the entity responsible for finding the correct PipelineExecutor to execute a given Pipeline.

Class Summary

Class	Description
DefaultExecutorServiceLoader	The default implementation of the PipelineExecutorServiceLoader.
DefaultJobExecutionStatusEvent	Default implementation for JobExecutionStatusEvent.
DetachedJobExecutionResult	The JobExecutionResult returned by a context environment when executing a job in detached mode.
JobStatusChangedListenerUtils	Util class for JobStatusChangedListener.

Enum Summary

Enum	Description
CheckpointingMode	The checkpointing mode defines what consistency guarantees the system gives in the presence of failures.
CheckpointType	Describes the type in which a checkpoint should be taken.
RecoveryClaimMode	Defines state files ownership when Flink restore from a given savepoint or retained checkpoint.
SavepointFormatType	Describes the binary format in which a savepoint should be taken.