pyspark.streaming.DStream.reduceByKey#

DStream.reduceByKey(func, numPartitions=None)[source]#

Return a new DStream by applying reduceByKey to each RDD.