不持久

將 DataFrame 標記為非持久性,並從記憶體和磁碟中移除所有與其相關區塊。

語法

unpersist(blocking: bool = False)

參數

參數 類型 說明
blocking 布爾 (bool) 是否要封鎖直到所有封鎖都被刪除。

退貨

DataFrame: 未持久化資料框架。

Notes

blocking 預設已改為 False 與 Scala 2.0 版本相符。

快取的資料會被叢集上所有 Spark 會話共享,因此不持久的資料會影響所有會話。

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]