Package org.apache.flink.api.common
-
Interface Summary Interface Description Archiveable<T extends Serializable> JobInfo TheJobInforepresents the meta information of current job.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.TaskInfo TheTaskInforepresents the meta information of current task. -
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.JobExecutionResult The result of a job execution.JobID Unique (at least statistically unique) identifier for a Flink Job.JobInfoImpl The default implementation ofJobInfo.JobSubmissionResult The result of submitting a job to a JobManager.Plan This class represents Flink programs, in the form of dataflow plans.RestartStrategyDescriptionUtils Utility class for describing restart strategies.SerializableSerializer<T extends com.esotericsoftware.kryo.Serializer<?> & Serializable> The wrapper to make serializer serializable.TaskInfoImpl The default implementation ofTaskInfo. -
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.JobStatus Possible states of a job once it has been accepted by the dispatcher. -
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.