pyspark.streaming.DStream.reduceByKey# DStream.reduceByKey(func, numPartitions=None)[source]# Return a new DStream by applying reduceByKey to each RDD.