pyspark.streaming.DStream.cache

DStream.cache()

Persist the RDDs of this DStream with the default storage level (MEMORY_ONLY).

pyspark.streaming.DStream.saveAsTextFiles pyspark.streaming.DStream.checkpoint