unpersist

Marca o DataFrame como não persistente e remove todos os blocos para ele da memória e do disco.

Sintaxe

unpersist(blocking: bool = False)

Parâmetros

Devoluções

DataFrame: DataFrame nãopersistido.

Observações

blocking o padrão foi alterado para False corresponder ao Scala em 2.0.

Os dados armazenados em cache são compartilhados em todas as sessões do Spark no cluster, portanto, nãopersistê-los afeta todas as sessões.

Exemplos

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