Package | Description |
---|---|
org.apache.flink.iteration |
Modifier and Type | Method and Description |
---|---|
static DataStreamList |
IterationBody.forEachRound(DataStreamList inputs,
IterationBody.PerRoundSubBody perRoundSubBody) |
DataStreamList |
IterationBodyResult.getFeedbackVariableStreams() |
DataStreamList |
IterationBodyResult.getOutputStreams() |
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.
|
static DataStreamList |
DataStreamList.of(org.apache.flink.streaming.api.datastream.DataStream<?>... streams) |
DataStreamList |
IterationBody.PerRoundSubBody.process(DataStreamList input) |
Modifier and Type | Method and Description |
---|---|
static DataStreamList |
IterationBody.forEachRound(DataStreamList inputs,
IterationBody.PerRoundSubBody perRoundSubBody) |
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.
|
DataStreamList |
IterationBody.PerRoundSubBody.process(DataStreamList input) |
IterationBodyResult |
IterationBody.process(DataStreamList variableStreams,
DataStreamList dataStreams)
This method creates the graph for the iteration body.
|
Constructor and Description |
---|
IterationBodyResult(DataStreamList feedbackVariableStreams,
DataStreamList outputStreams) |
IterationBodyResult(DataStreamList feedbackVariableStreams,
DataStreamList outputStreams,
org.apache.flink.streaming.api.datastream.DataStream<?> terminationCriteria) |
Copyright © 2019–2023 The Apache Software Foundation. All rights reserved.