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.

Önbelleğe alınan veriler kümedeki tüm Spark oturumlarında paylaşılır.

Örnekler

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

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