pyflink.datastream.data_stream.CachedDataStream.shuffle#
- CachedDataStream.shuffle() DataStream#
Sets the partitioning of the DataStream so that the output elements are shuffled uniformly randomly to the next operation.
- Returns
The DataStream with shuffle partitioning set.