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