快取

以預設儲存層MEMORY_AND_DISK_DESER級()持續保存資料框架。

語法

cache()

退貨

DataFrame:快取資料幀。

Notes

預設儲存等級已調整為 MEMORY_AND_DISK_DESER 與 Scala 3.0 版本相符。

在經典運算中,快取資料會在叢集上所有 Spark 會話間共享。

在無伺服器運算中,會 cache() 立即執行查詢,並將結果存到整個會話中。 只有你的工作階段能讀取,且當來源資料表改變時,結果不會改變。 請參見 無伺服器運算上的快取資料框架(Cache DataFrames)。

Examples

df = spark.range(1)
df.cache()
# DataFrame[id: bigint]

df.explain()
# == Physical Plan ==
# InMemoryTableScan ...