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