pyspark.streaming.DStream.checkpoint#

DStream.checkpoint(interval)[source]#

Enable periodic checkpointing of RDDs of this DStream

Parameters
intervalint

time in seconds, after each period of that, generated RDD will be checkpointed