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