pyspark.streaming.DStream.reduce

DStream。 减少 ( 函数:可调用的((T,T],T] )→pyspark.streaming.dstream.DStream(T]

返回一个新的DStream每个抽样有单个元素通过减少每个抽样生成DStream。

以前的

pyspark.streaming.DStream.persist

下一个

pyspark.streaming.DStream.reduceByKey