保留默认存储级别的 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 ...