Vizualizarea tabelelor
După ce ai creat o SparkSession, poți începe să explorezi ce date există în clusterul tău!
SparkSession-ul tău are un atribut numit catalog, care listează toate datele din cluster. Acest atribut oferă câteva metode pentru a extrage diferite tipuri de informații.
Una dintre cele mai utile este metoda .listTables(), care returnează numele tuturor tabelelor din cluster sub forma unei liste.
Acest exercițiu face parte din cursul
Fundamente PySpark
Instrucțiuni pentru exercițiu
- Verifică ce tabele există în clusterul tău apelând
spark.catalog.listTables()și afișând rezultatul!
Exercițiu interactiv practic
Încearcă acest exercițiu completând acest cod de exemplu.
# Print the tables in the catalog
print(spark.____.____())