DStream.
reduce
Return a new DStream in which each RDD has a single element generated by reducing each RDD of this DStream.
previous
pyspark.streaming.DStream.persist
next
pyspark.streaming.DStream.reduceByKey