pyspark.streaming.DStream.reduce

DStream.reduce(func)

Return a new DStream in which each RDD has a single element generated by reducing each RDD of this DStream.

pyspark.streaming.DStream.persist pyspark.streaming.DStream.reduceByKey