pyspark.streaming.DStream.countByValue ====================================== .. currentmodule:: pyspark.streaming .. automethod:: DStream.countByValue