cache

Mempertahankan DataFrame dengan tingkat penyimpanan default (MEMORY_AND_DISK_DESER).

Sintaksis

cache()

Pengembalian Barang

DataFrame: DataFrame yang di-cache.

Catatan

Tingkat penyimpanan default telah berubah agar MEMORY_AND_DISK_DESER sesuai dengan Scala di 3.0.

Pada komputasi klasik, data cache dibagikan ke semua sesi Spark di cluster.

Di komputasi serverless, cache() jalankan kueri langsung dan menyimpan hasilnya untuk sisa sesi Anda. Hanya sesi Anda yang bisa membacanya, dan hasilnya tidak berubah saat tabel sumber berubah. Lihat Cache DataFrames pada komputasi serverless.

Examples

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

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