gyorsítótár

Megőrzi a DataFrame-et az alapértelmezett tárolási szinttel (MEMORY_AND_DISK_DESER).

Szemantika

cache()

Visszatérítések

DataFrame: Gyorsítótárazott adatkeret.

Jegyzetek

Az alapértelmezett tárolási szint úgy módosult, hogy MEMORY_AND_DISK_DESER megfeleljen a Scala 3.0-s értékének.

A gyorsítótárazott adatok megosztásra kerülnek a klaszter összes Spark munkamenetében.

Examples

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

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