pyspark.streaming.DStream.reduceByKey

DStream.reduceByKey(func: Callable[[V, V], V], numPartitions: Optional[int] = None) → pyspark.streaming.dstream.DStream[Tuple[K, V]]

Return a new DStream by applying reduceByKey to each RDD.

pyspark.streaming.DStream.reduce pyspark.streaming.DStream.reduceByKeyAndWindow