以預設儲存層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 ...