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