pyspark.RDD.cache#

RDD.cache()[source]#

Persist this RDD with the default storage level (MEMORY_ONLY).

New in version 0.7.0.

Returns

RDD

The sameRDD with storage level set toMEMORY_ONLY

See also

RDD.persist()

RDD.unpersist()

RDD.getStorageLevel()

Examples

>>>rdd=sc.range(5)>>>rdd2=rdd.cache()>>>rdd2isrddTrue>>>str(rdd.getStorageLevel())'Memory Serialized 1x Replicated'>>>_=rdd.unpersist()