# pyspark.streaming.DStream.repartition¶

DStream.repartition(numPartitions)[source]

Return a new DStream with an increased or decreased level of parallelism.