ÎncepețiÎncepe gratuit

Stocarea și eliminarea din cache a tabelelor

În lecție am învățat că tabelele pot fi stocate în cache. În timp ce un DataFrame se stochează în cache folosind operația cache sau persist, un tabel se stochează în cache folosind operația cacheTable.

Este disponibil un tabel numit table1.

Acest exercițiu face parte din cursul

Introducere în Spark SQL în Python

Vezi cursul

Instrucțiuni pentru exercițiu

  • Listează tabelele folosind metoda listTables().
  • Stochează table1 în cache și confirmă că a fost stocat.
  • Elimină table1 din cache și confirmă că a fost eliminat.

Exercițiu interactiv practic

Încearcă acest exercițiu completând acest cod de exemplu.

# List the tables
print("Tables:\n", spark.____.____())

# Cache table1 and Confirm that it is cached
spark.catalog.____('table1')
print("table1 is cached: ", spark.catalog.____('table1'))

# Uncache table1 and confirm that it is uncached
spark.catalog.____('table1')
print("table1 is cached: ", spark.catalog.____('table1'))
Editează și rulează codul