pyspark.streaming.DStream.countByValue

DStream。 countByValue ( )→pyspark.streaming.dstream.DStream(元组(K,int] ]

返回一个新的DStream每个抽样包含项的每个不同的值在每个抽样DStream。

以前的

pyspark.streaming.DStream.count

下一个

pyspark.streaming.DStream.countByValueAndWindow