unpersist

Markeert het DataFrame als niet-persistent en verwijder alle blokken ervoor uit het geheugen en de schijf.

Syntaxis

unpersist(blocking: bool = False)

Parameterwaarden

Kenmerk Typ Beschrijving
blocking bool Of u wilt blokkeren totdat alle blokken worden verwijderd.

Retouren

DataFrame: Niet-gepersisteerd DataFrame.

Aantekeningen

blocking standaard is gewijzigd zodat False deze overeenkomt met Scala in 2.0.

Gegevens in de cache worden gedeeld in alle Spark-sessies in het cluster, dus het onpersistent is van invloed op alle sessies.

Examples

df = spark.range(1)
df.persist()
# DataFrame[id: bigint]
df.unpersist()
# DataFrame[id: bigint]
df = spark.range(1)
df.unpersist(True)
# DataFrame[id: bigint]