pyspark.streaming.DStream.repartition# DStream.repartition(numPartitions)[source]# Return a new DStream with an increased or decreased level of parallelism.