cache

DataFrame'i varsayılan depolama düzeyiyle () kalıcı hale getirirMEMORY_AND_DISK_DESER.

Sözdizimi

cache()

İadeler

DataFrame: Önbelleğe Alınmış DataFrame.

Notlar

Varsayılan depolama düzeyi, 3.0'da Scala ile eşleşecek şekilde MEMORY_AND_DISK_DESER değiştirildi.

Klasik hesaplamada, önbelleğe alınan veriler kümedeki tüm Spark oturumları arasında paylaşılır.

Sunucusuz hesaplamada, cache() sorguyu hemen çalıştırır ve sonucu oturumunuzun geri kalanı için saklar. Sadece oturumunuz okuyabilir ve kaynak tablolar değiştiğinde sonuç değişmez. Bkz. Cache DataFrames (Sunucusuz hesaplamada).

Örnekler

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

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