pyspark.streaming.DStream.reduce

DStream。 減少 ( 函數:可調用的((T,T],T] )→pyspark.streaming.dstream.DStream(T]

返回一個新的DStream每個抽樣有單個元素通過減少每個抽樣生成DStream。

以前的

pyspark.streaming.DStream.persist

下一個

pyspark.streaming.DStream.reduceByKey