pyspark.streaming.DStream.reduceByKey

DStream.reduceByKey(func, numPartitions=None)

Return a new DStream by applying reduceByKey to each RDD.

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