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.
Builder for the
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.
Utilities for generating
Enum to distinguish JobGraphs between batch and streaming, currently used by the scheduler.
Defines how Flink should restore from a given savepoint or retained checkpoint.
Copyright © 2014–2022 The Apache Software Foundation. All rights reserved.