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