Package | Description |
---|---|
org.apache.flink.iteration |
Modifier and Type | Method and Description |
---|---|
static DataStreamList |
Iterations.iterateBoundedStreamsUntilTermination(DataStreamList initVariableStreams,
ReplayableDataStreamList dataStreams,
IterationConfig config,
IterationBody body)
This method uses an iteration body to process records in some bounded data streams
iteratively until no more records are iterating or the given terminating criteria stream is
empty in one round.
|
static DataStreamList |
Iterations.iterateUnboundedStreams(DataStreamList initVariableStreams,
DataStreamList dataStreams,
IterationBody body)
This method uses an iteration body to process records in possibly unbounded data streams.
|
Copyright © 2019–2023 The Apache Software Foundation. All rights reserved.