將 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]