bufor

Utrwala ramkę danych przy użyciu domyślnego poziomu magazynu (MEMORY_AND_DISK_DESER).

Składnia

cache()

Zwroty

DataFrame: Buforowana ramka danych.

Notatki

Domyślny poziom magazynu został zmieniony na MEMORY_AND_DISK_DESER zgodny ze skalą w wersji 3.0.

W klasycznym trybie compute, dane buforowane są współdzielone między wszystkimi sesjami Spark w klastrze.

Na serwerowym komputerze cache() uruchamia zapytanie od razu i przechowuje wynik na resztę sesji. Tylko sesja może go odczytać, a wynik nie zmienia się, gdy zmieniają się tabele źródłowe. Zobacz Cache DataFrames na serwerowym przetwarzaniu.

Examples

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

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