Package | Description |
---|---|
org.apache.flink.iteration |
Modifier and Type | Class and Description |
---|---|
static class |
ReplayableDataStreamList.NonReplayedDataStreamList
A special
ReplayableDataStreamList that all streams should be not replayed. |
static class |
ReplayableDataStreamList.ReplayedDataStreamList
A special
ReplayableDataStreamList that all streams should be replayed. |
Modifier and Type | Method and Description |
---|---|
ReplayableDataStreamList |
ReplayableDataStreamList.ReplayedDataStreamList.andNotReplay(org.apache.flink.streaming.api.datastream.DataStream<?>... nonReplayedStreams) |
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.
|
Copyright © 2019–2023 The Apache Software Foundation. All rights reserved.