Nota
L'accesso a questa pagina richiede l'autorizzazione. È possibile provare ad accedere o modificare le directory.
L'accesso a questa pagina richiede l'autorizzazione. È possibile provare a modificare le directory.
Contrassegna il dataframe come non persistente e rimuove tutti i blocchi per esso dalla memoria e dal disco.
Sintassi
unpersist(blocking: bool = False)
Parametri
| Parametro | Tipo | Descrizione |
|---|---|---|
blocking |
bool | Indica se bloccare fino a quando non vengono eliminati tutti i blocchi. |
Restituzioni
DataFrame: dataframe non persistente.
Note
blocking il valore predefinito è stato modificato in False in modo che corrisponda a Scala nella versione 2.0.
I dati memorizzati nella cache vengono condivisi in tutte le sessioni Spark nel cluster, quindi l'annullamento dell'operazione influisce su tutte le sessioni.
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]