pyspark.streaming.DStream.reduce

DStream.reduce(func: Callable[[T, T], T]) → pyspark.streaming.dstream.DStream[T]

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