pyflink.datastream.data_stream.CachedDataStream.forward

CachedDataStream.forward() → pyflink.datastream.data_stream.DataStream

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.