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 batchExecutionOptions.RUNTIME_MODEif the shuffling behavior has not been set explicitly for an individual exchange.ExecutionConfig.ClosureCleanerLevel Configuration settings for the closure cleaner.ExecutionMode Deprecated. TheExecutionModeis deprecated because it's only used in DataSet APIs.InputDependencyConstraint Deprecated. InputDependencyConstraintis 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 theInvalidProgramException, indicating that a part of the program that needs to be serializable (for shipping) is not serializable.