|Archiveable<T extends Serializable>
Implementing this interface allows a Program to have a description of the plan which can be shown to the user.
Serializable class which is created when archiving the job.
A config to define the behavior of the program execution.
Abstract class for a custom user configuration object registered at the execution config.
|ExecutionConfig.SerializableSerializer<T extends com.esotericsoftware.kryo.Serializer<?> & Serializable>
The result of a job execution.
Unique (at least statistically unique) identifier for a Flink Job.
The result of submitting a job to a JobManager.
This class represents Flink programs, in the form of dataflow plans.
Encapsulates task-specific information: name, index of subtask, parallelism and attempt number.
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.
The code analysis code has been removed and this enum has no effect.
Configuration settings for the closure cleaner.
The execution mode specifies how a batch program is executed in terms of data exchange: pipelining or batched.
InputDependencyConstraint is not used anymore and will be deleted in one of
the future versions.
Possible states of a job once it has been accepted by the dispatcher.
Runtime execution mode of DataStream programs.
An exception thrown to indicate that the composed program is invalid.
An special case of the
InvalidProgramException, indicating that a part of the program
that needs to be serializable (for shipping) is not serializable.
Copyright © 2014–2024 The Apache Software Foundation. All rights reserved.