org.apache.flink.streaming.python.api.datastream

Class PythonIterativeStream

java.lang.Object

org.apache.flink.streaming.python.api.datastream.PythonDataStream<SingleOutputStreamOperator<org.python.core.PyObject>>

org.apache.flink.streaming.python.api.datastream.PythonSingleOutputStreamOperator

org.apache.flink.streaming.python.api.datastream.PythonIterativeStream

@PublicEvolving
public class PythonIterativeStream
extends PythonSingleOutputStreamOperator

A thin wrapper layer over IterativeStream.

The python iterative data stream represents the start of an iteration in a PythonDataStream.

Field Summary

Fields inherited from class org.apache.flink.streaming.python.api.datastream.PythonDataStream

stream

Method Summary

Modifier and Type	Method and Description
PythonDataStream	close_with(PythonDataStream<? extends DataStream<org.python.core.PyObject>> feedback_stream) A thin wrapper layer over IterativeStream.closeWith(org.apache.flink.streaming.api.datastream.DataStream)

Methods inherited from class org.apache.flink.streaming.python.api.datastream.PythonSingleOutputStreamOperator

name

Methods inherited from class org.apache.flink.streaming.python.api.datastream.PythonDataStream

add_sink, filter, flat_map, iterate, iterate, key_by, map, output, split, union, write_as_text, write_as_text, write_to_socket

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Method Detail

close_with

public PythonDataStream close_with(PythonDataStream<? extends DataStream<org.python.core.PyObject>> feedback_stream)

A thin wrapper layer over IterativeStream.closeWith(org.apache.flink.streaming.api.datastream.DataStream)

Please note that this function works with PythonDataStream and thus wherever a DataStream is mentioned in the above IterativeStream.closeWith(org.apache.flink.streaming.api.datastream.DataStream) description, the user may regard it as PythonDataStream .

Parameters:

feedback_stream - PythonDataStream that will be used as input to the iteration head.

Returns:

The feedback stream.