An intermediate data set is the data set produced by an operator - either a source or any intermediate operation.
This class represent edges (communication channels) in a job graph.
The JobGraph represents a Flink dataflow program, at the low level that the JobManager accepts.
The base class for job vertexes.
A class for statistically unique job vertex IDs.
A class for statistically unique operator IDs.
An ID for physical instance of the operator.
A task vertex that run an initialization on the master, trying to deserialize an output format and initializing it on master, if necessary.
Savepoint restore settings.
A distribution pattern determines, which sub tasks of a producing task are connected to which consuming sub tasks.
Possible states of a job once it has been accepted by the job manager.
The ScheduleMode decides how tasks of an execution graph are started.
Copyright © 2014–2020 The Apache Software Foundation. All rights reserved.