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.