unpersist

Oznacza ramkę danych jako nietrwalą i usuń wszystkie bloki z pamięci i dysku.

Składnia

unpersist(blocking: bool = False)

Parametry

Parameter Typ Opis
blocking bool Czy zablokować, dopóki wszystkie bloki nie zostaną usunięte.

Zwroty

DataFrame: Niezapersyjowana ramka danych.

Notatki

blocking wartość domyślna została zmieniona na False zgodną ze scalą w wersji 2.0.

Buforowane dane są współużytkowane we wszystkich sesjach platformy Spark w klastrze, więc niezakłócanie wpływa na wszystkie sesje.

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]