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.

Klasszikus számítástechnikán a gyorsatározott adatokat megosztják a klaszterben lévő összes Spark munkamenet között.

Szerver nélküli számítás cache() esetén azonnal lefuttatja a lekérdezést, és az eredményt a továbbiakban tárolja. Csak a te ülésed tudja olvasni, és az eredmény nem változik, amikor a forrástáblák változnak. Lásd : Cache DataFrames szerver nélküli számításon.

Examples

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

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