快取

保留默认存储级别的 DataFrame(MEMORY_AND_DISK_DESER)。

Syntax

cache()

退货

DataFrame:缓存的数据帧。

备注

默认存储级别已更改为 MEMORY_AND_DISK_DESER 匹配 3.0 中的 Scala。

在经典计算中,缓存数据会在集群上的所有 Spark 会话间共享。

在无服务器计算中,会 cache() 立即运行查询,并将结果存储到会话的其余部分。 只有你的会话能读取它,源表变更时结果也不会改变。 参见 无服务器计算中的缓存数据帧。

示例

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

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