Freigeben über


Unpersist

Markiert den DataFrame als nicht persistent, und entfernt alle Blöcke dafür aus dem Arbeitsspeicher und dem Datenträger.

Syntax

unpersist(blocking: bool = False)

Parameter

Parameter Typ Beschreibung
blocking bool Gibt an, ob blockiert werden soll, bis alle Blöcke gelöscht werden.

Rückkehr

DataFrame: Unpersisted DataFrame.

Hinweise

blocking Der Standardwert wurde in False 2.0 auf Scala geändert.

Zwischengespeicherte Daten werden für alle Spark-Sitzungen im Cluster freigegeben, sodass sich dies auf alle Sitzungen auswirkt.

Beispiele

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