DStream。
reduceByKey
返回一個新的DStream運用reduceByKey抽樣。
以前的
pyspark.streaming.DStream.reduce
下一個
pyspark.streaming.DStream.reduceByKeyAndWindow