pyflink.datastream.data_stream.DataStream.forward# DataStream.forward() → pyflink.datastream.data_stream.DataStream[source]# Sets the partitioning of the DataStream so that the output elements are forwarded to the local sub-task of the next operation. Returns The DataStream with forward partitioning set.