pyspark.RDD.unpersist

RDD.unpersist(blocking: bool = False) → pyspark.rdd.RDD[T][source]

Mark the RDD as non-persistent, and remove all blocks for it from memory and disk.

Changed in version 3.0.0: Added optional argument blocking to specify whether to block until all blocks are deleted.