unpersist

Markerar DataFrame som icke-beständig och tar bort alla block för den från minne och disk.

Syntax

unpersist(blocking: bool = False)

Parameters

Parameter Type Beskrivning
blocking bool Om du vill blockera tills alla block har tagits bort.

Retur

DataFrame: Ej framtappad dataram.

Notes

blocking standardvärdet har ändrats till False att matcha Scala i 2.0.

Cachelagrade data delas över alla Spark-sessioner i klustret, så om du avpersisterar dem påverkas alla sessioner.

Exempel

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