DStream。
countByValue
返回一個新的DStream每個抽樣包含項的每個不同的值在每個抽樣DStream。
以前的
pyspark.streaming.DStream.count
下一個
pyspark.streaming.DStream.countByValueAndWindow