|Archiveable<T extends Serializable>|
A Program represents and end-to-end Flink program.
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.
A PlanExecutor executes a Flink program's dataflow plan.
Encapsulates task-specific information: name, index of subtask, parallelism and attempt number.
Specifies to which extent user-defined functions are analyzed in order to give the Flink optimizer an insight of UDF internals and inform the user about common implementation mistakes.
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.
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.