pyspark.streaming.DStream.reduceByKey

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

Return a new DStream by applying reduceByKey to each RDD.