Nota:
El acceso a esta página requiere autorización. Puede intentar iniciar sesión o cambiar directorios.
El acceso a esta página requiere autorización. Puede intentar cambiar los directorios.
Marca el DataFrame como no persistente y quita todos los bloques de memoria y disco.
Sintaxis
unpersist(blocking: bool = False)
Parámetros
| Parámetro | Tipo | Descripción |
|---|---|---|
blocking |
bool | Si se va a bloquear hasta que se eliminen todos los bloques. |
Devoluciones
DataFrame: DataFrame no supervisado.
Notas
blocking default ha cambiado a para False que coincida con Scala en 2.0.
Los datos almacenados en caché se comparten en todas las sesiones de Spark en el clúster, por lo que la falta de experiencia afecta a todas las sesiones.
Ejemplos
df = spark.range(1)
df.persist()
# DataFrame[id: bigint]
df.unpersist()
# DataFrame[id: bigint]
df = spark.range(1)
df.unpersist(True)
# DataFrame[id: bigint]