pyspark.RDD.unpersist

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

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

Added optional argument blocking to specify whether to block until all blocks are deleted.

previous

pyspark.RDD.union

next

pyspark.RDD.values