A task vertex that runs an initialization and a finalization on the master.
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.
Savepoint restore settings.
A distribution pattern determines, which sub tasks of a producing task are connected to which consuming sub tasks.
The ScheduleMode decides how tasks of an execution graph are started.
Copyright © 2014–2019 The Apache Software Foundation. All rights reserved.