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