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.

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
CodeAnalysisMode	Deprecated The code analysis code has been removed and this enum has no effect.
ExecutionConfig.ClosureCleanerLevel	Configuration settings for the closure cleaner.
ExecutionMode	The execution mode specifies how a batch program is executed in terms of data exchange: pipelining or batched.
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.