|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.
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.
This constraint indicates when a task should be scheduled considering its inputs status.
Possible states of a job once it has been accepted by the job manager.
An exception thrown to indicate that the composed program is invalid.
An special case of the
Copyright © 2014–2020 The Apache Software Foundation. All rights reserved.