pyspark.streaming.DStream.repartition ===================================== .. currentmodule:: pyspark.streaming .. automethod:: DStream.repartition