Oharra
Baimena behar duzu orria atzitzeko. Direktorioetan saioa has dezakezu edo haiek alda ditzakezu.
Baimena behar duzu orria atzitzeko. Direktorioak alda ditzakezu.
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]