Interface | Description |
---|---|
IterationBody |
The builder of the subgraph that will be executed inside the iteration.
|
IterationBody.PerRoundSubBody |
The sub-graph inside the iteration body that should be executed as per-round.
|
IterationListener<T> |
The callbacks which will be invoked if the operator or UDF inside iteration implement this
interface.
|
IterationListener.Context |
Information available in an invocation of the callbacks defined in the
IterationProgressListener.
|
Class | Description |
---|---|
DataStreamList |
A utility class to maintain a list of
DataStream , which might have different types. |
IterationBodyResult |
The result of an iteration, specifying the feedbacks and the outputs.
|
IterationConfig |
The config for an iteration.
|
IterationConfig.IterationConfigBuilder |
The builder of the
IterationConfig . |
IterationID |
The id of a single iteration instance in the job graph.
|
IterationRecord<T> |
The wrapper for the records in iterative stream.
|
Iterations |
A helper class to create iterations.
|
ReplayableDataStreamList |
A list of data streams and whether they need replayed.
|
ReplayableDataStreamList.NonReplayedDataStreamList |
A special
ReplayableDataStreamList that all streams should be not replayed. |
ReplayableDataStreamList.ReplayedDataStreamList |
A special
ReplayableDataStreamList that all streams should be replayed. |
Enum | Description |
---|---|
IterationConfig.OperatorLifeCycle |
LifeCycles of the operator inside the iteration.
|
IterationRecord.Type |
The type of iteration records.
|
Copyright © 2019–2023 The Apache Software Foundation. All rights reserved.