pyflink.datastream.data_stream.DataStream.shuffle# DataStream.shuffle() → pyflink.datastream.data_stream.DataStream[source]# 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.