<F> IterativeStream.ConnectedIterativeStreams<T,F> |
IterativeStream.withFeedbackType(Class<F> feedbackTypeClass) |
Changes the feedback type of the iteration and allows the user to apply co-transformations on
the input and feedback stream, as in a ConnectedStreams.
|
<F> IterativeStream.ConnectedIterativeStreams<T,F> |
IterativeStream.withFeedbackType(org.apache.flink.api.common.typeinfo.TypeHint<F> feedbackTypeHint) |
Changes the feedback type of the iteration and allows the user to apply co-transformations on
the input and feedback stream, as in a ConnectedStreams.
|
<F> IterativeStream.ConnectedIterativeStreams<T,F> |
IterativeStream.withFeedbackType(org.apache.flink.api.common.typeinfo.TypeInformation<F> feedbackType) |
Changes the feedback type of the iteration and allows the user to apply co-transformations on
the input and feedback stream, as in a ConnectedStreams.
|