@Experimental public class IterationBodyResult extends Object
Constructor and Description |
---|
IterationBodyResult(DataStreamList feedbackVariableStreams,
DataStreamList outputStreams) |
IterationBodyResult(DataStreamList feedbackVariableStreams,
DataStreamList outputStreams,
org.apache.flink.streaming.api.datastream.DataStream<?> terminationCriteria) |
Modifier and Type | Method and Description |
---|---|
DataStreamList |
getFeedbackVariableStreams() |
DataStreamList |
getOutputStreams() |
org.apache.flink.streaming.api.datastream.DataStream<?> |
getTerminationCriteria() |
public IterationBodyResult(DataStreamList feedbackVariableStreams, DataStreamList outputStreams)
public IterationBodyResult(DataStreamList feedbackVariableStreams, DataStreamList outputStreams, @Nullable org.apache.flink.streaming.api.datastream.DataStream<?> terminationCriteria)
public DataStreamList getFeedbackVariableStreams()
public DataStreamList getOutputStreams()
@Nullable public org.apache.flink.streaming.api.datastream.DataStream<?> getTerminationCriteria()
Copyright © 2019–2023 The Apache Software Foundation. All rights reserved.