pyspark.streaming.DStream.cache#

DStream.cache()[source]#

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