uncacheTable

Hiermee verwijdert u de opgegeven tabel uit de cache in het geheugen.

Syntaxis

uncacheTable(tableName: str)

Parameterwaarden

Kenmerk Typ Beschrijving
tableName str De naam van de tabel die moet worden opgehaald. Kan worden gekwalificeerd met de naam van de catalogus.

Aantekeningen

Gegevens in de cache worden gedeeld in alle Spark-sessies in het cluster, dus het loskoppelen van deze gegevens is van invloed op alle sessies.

Examples

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

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

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