メインコンテンツまでスキップ

キャッシュ

DataFrameまだストレージ レベル ( MEMORY_AND_DISK_DESER ) で永続化します。

構文

cache()

戻り値

DataFrame: キャッシュされたDataFrame 。

注意

デフォルトのストレージレベルが、Scala 3.0に合わせてMEMORY_AND_DISK_DESERに変更されました。

キャッシュされたデータは、クラスター上のすべてのSparkセッション間で共有されます。

:::note サーバレスの互換性

Databricks は、Databricks サーバレス コンピュート アーキテクチャと互換性がないため、DataFrame.cache()の使用を推奨しません。代わりに、中間結果をDeltaテーブルにマテリアライズします。

:::

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

df.explain()
# == Physical Plan ==
# InMemoryTableScan ...
このページの見出し