Hinweis
Für den Zugriff auf diese Seite ist eine Autorisierung erforderlich. Sie können versuchen, sich anzumelden oder das Verzeichnis zu wechseln.
Für den Zugriff auf diese Seite ist eine Autorisierung erforderlich. Sie können versuchen, das Verzeichnis zu wechseln.
Speichert die angegebene Tabelle im Arbeitsspeicher oder mit einer bestimmten Speicherebene zwischen. Standard-MEMORY_AND_DISK.
Syntax
cacheTable(tableName: str, storageLevel: StorageLevel = None)
Parameter
| Parameter | Typ | Beschreibung |
|---|---|---|
tableName |
str | Name der abzurufenden Tabelle. Kann mit Katalognamen qualifiziert werden. |
storageLevel |
StorageLevelwahlfrei |
Speicherebene, die für Persistenz festgelegt werden soll. |
Hinweise
Zwischengespeicherte Daten werden für alle Spark-Sitzungen im Cluster freigegeben.
Beispiele
_ = 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")