pyspark.streaming.DStream.repartition

DStream.repartition(numPartitions: int) → pyspark.streaming.dstream.DStream[T]

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

previous

pyspark.streaming.DStream.reduceByWindow

next

pyspark.streaming.DStream.rightOuterJoin