pyspark.streaming.DStream.repartition

DStream.repartition(numPartitions)

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

pyspark.streaming.DStream.reduceByWindow pyspark.streaming.DStream.rightOuterJoin