pyspark.streaming.DStream.reduce# DStream.reduce(func)[source]# Return a new DStream in which each RDD has a single element generated by reducing each RDD of this DStream.