pyspark.streaming.DStream.reduceByKey

DStream。 reduceByKey ( 函數:可調用的((V,V],V],numPartitions:可選(int]=沒有一個 )→pyspark.streaming.dstream.DStream(元組(K,V] ]

返回一個新的DStream運用reduceByKey抽樣。

以前的

pyspark.streaming.DStream.reduce

下一個

pyspark.streaming.DStream.reduceByKeyAndWindow