cache

Bevarar DataFrame med standardlagringsnivån (MEMORY_AND_DISK_DESER).

Syntax

cache()

Retur

DataFrame: Cachelagrad dataram.

Notes

Standardlagringsnivån har ändrats till MEMORY_AND_DISK_DESER att matcha Scala i 3.0.

Cachelagrade data delas över alla Spark-sessioner i klustret.

Exempel

:::obs Serverlös kompatibilitet

Databricks rekommenderar att du flyttar från DataFrame.cache() eftersom det inte är kompatibelt med databricks serverlös beräkningsarkitektur. Materialisera mellanliggande resultat till en Delta-tabell i stället.

:::

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

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