pyspark.streaming.DStream.countByValue

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

返回一個新的DStream每個抽樣包含項的每個不同的值在每個抽樣DStream。

以前的

pyspark.streaming.DStream.count

下一個

pyspark.streaming.DStream.countByValueAndWindow