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.
JobListener	A listener that is notified on specific job status changed, which should be firstly registered by #registerJobListener of execution environments.
JobStatusHook	Hooks on job status changing.
PipelineExecutor	The entity responsible for executing a Pipeline, i.e.
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.
DetachedJobExecutionResult	The JobExecutionResult returned by a context environment when executing a job in detached mode.

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.
RestoreMode	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.