pyspark.streaming.DStream.cache

DStream.cache() → pyspark.streaming.dstream.DStream[T]

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

previous

pyspark.streaming.DStream.saveAsTextFiles

next

pyspark.streaming.DStream.checkpoint