Class and Description |
---|
DataStreamList
A utility class to maintain a list of
DataStream , which might have different types. |
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.
|
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 . |
IterationConfig.OperatorLifeCycle
LifeCycles of the operator inside the iteration.
|
IterationListener.Context
Information available in an invocation of the callbacks defined in the
IterationProgressListener.
|
IterationRecord
The wrapper for the records in iterative stream.
|
IterationRecord.Type
The type of iteration records.
|
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. |
Class and Description |
---|
IterationID
The id of a single iteration instance in the job graph.
|
IterationListener
The callbacks which will be invoked if the operator or UDF inside iteration implement this
interface.
|
IterationRecord
The wrapper for the records in iterative stream.
|
Class and Description |
---|
IterationRecord
The wrapper for the records in iterative stream.
|
Class and Description |
---|
IterationID
The id of a single iteration instance in the job graph.
|
Class and Description |
---|
IterationRecord
The wrapper for the records in iterative stream.
|
Class and Description |
---|
IterationRecord
The wrapper for the records in iterative stream.
|
Class and Description |
---|
IterationRecord
The wrapper for the records in iterative stream.
|
Class and Description |
---|
IterationRecord
The wrapper for the records in iterative stream.
|
Class and Description |
---|
IterationListener
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.
|
Copyright © 2019–2023 The Apache Software Foundation. All rights reserved.