cache

Сохраняет кадр данных с уровнем хранилища по умолчанию (MEMORY_AND_DISK_DESER).

Синтаксис

cache()

Возвраты

DataFrame: кэшированный кадр данных.

Примечания

Уровень хранения по умолчанию изменился на MEMORY_AND_DISK_DESER соответствие Scala в версии 3.0.

В классических вычислениях кэшированные данные используются между всеми сессиями Spark в кластере.

На серверных вычислениях cache() запрос запускается сразу и сохраняет результат на всю оставшуюся сессию. Только ваша сессия может её прочитать, и результат не меняется при изменении исходных таблиц. См. Cache DataFrames на серверных вычислениях.

Примеры

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

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