cacheTable

Cachelagrar den angivna tabellen i minnet eller med angiven lagringsnivå. Standard MEMORY_AND_DISK.

Syntax

cacheTable(tableName: str, storageLevel: StorageLevel = None)

Parameters

Parameter Type Beskrivning
tableName str Namnet på tabellen som ska hämtas. Kan kvalificeras med katalognamn.
storageLevel StorageLevelvalfri Lagringsnivå som ska anges för beständighet.

Notes

Cachelagrade data delas över alla Spark-sessioner i klustret.

Exempel

_ = spark.sql("DROP TABLE IF EXISTS tbl1")
_ = spark.sql("CREATE TABLE tbl1 (name STRING, age INT) USING parquet")
spark.catalog.cacheTable("tbl1")

# or

spark.catalog.cacheTable("tbl1", StorageLevel.OFF_HEAP)

# Throw an analysis exception when the table does not exist.
spark.catalog.cacheTable("not_existing_table")
# Traceback (most recent call last):
#     ...
# AnalysisException: ...

# Using the fully qualified name for the table.
spark.catalog.cacheTable("spark_catalog.default.tbl1")
spark.catalog.uncacheTable("tbl1")
_ = spark.sql("DROP TABLE tbl1")