Package org.apache.flink.api.common

Interface Summary

Interface	Description
Archiveable<T extends Serializable>
ProgramDescription	Implementing this interface allows a Program to have a description of the plan which can be shown to the user.
SupportsConcurrentExecutionAttempts	The interface indicates that it supports multiple attempts executing at the same time.

Class Summary

Class	Description
ArchivedExecutionConfig	Serializable class which is created when archiving the job.
ExecutionConfig	A config to define the behavior of the program execution.
ExecutionConfig.GlobalJobParameters	Abstract class for a custom user configuration object registered at the execution config.
ExecutionConfig.SerializableSerializer<T extends com.esotericsoftware.kryo.Serializer<?> & Serializable>
JobExecutionResult	The result of a job execution.
JobID	Unique (at least statistically unique) identifier for a Flink Job.
JobSubmissionResult	The result of submitting a job to a JobManager.
Plan	This class represents Flink programs, in the form of dataflow plans.
TaskInfo	Encapsulates task-specific information: name, index of subtask, parallelism and attempt number.

Enum Summary

Enum	Description
BatchShuffleMode	Defines how data is exchanged between tasks in batch ExecutionOptions.RUNTIME_MODE if the shuffling behavior has not been set explicitly for an individual exchange.
ExecutionConfig.ClosureCleanerLevel	Configuration settings for the closure cleaner.
ExecutionMode	Deprecated The ExecutionMode is deprecated because it's only used in DataSet APIs.
InputDependencyConstraint	Deprecated InputDependencyConstraint is not used anymore and will be deleted in one of the future versions.
JobStatus	Possible states of a job once it has been accepted by the dispatcher.
RuntimeExecutionMode	Runtime execution mode of DataStream programs.

Exception Summary

Exception	Description
InvalidProgramException	An exception thrown to indicate that the composed program is invalid.
NonSerializableUserCodeException	An special case of the InvalidProgramException, indicating that a part of the program that needs to be serializable (for shipping) is not serializable.