dexblog.ro
Acces rapid: Învață AI Învață Programare Specificații Dispozitive Comparații
SPARK Toate comenzile Apache Spark & PySpark

Salvarea Tabelelor Gestionate cu df.write.saveAsTable în Apache Spark & PySpark

io Apache Spark 3.5 / PySpark Q&A / Distribuie cod

Înregistrarea DataFrame-ului ca tabel gestionat în catalogul de metadate Hive Metastore sau Databricks Unity Catalog.

Sintaxă 
df.write.format('parquet').mode('overwrite').saveAsTable('db.tabel')

Metoda saveAsTable() persistă datele fizice și înregistrează simultan metadatele (numele tabelei, schema coloanelor și locația fișierelor) în catalogul de date centralizat (cum ar fi Hive Metastore, AWS Glue sau Unity Catalog).

Odată salvat astfel, tabelul poate fi interogat direct prin comenzi SQL native de către orice sesiune Spark sau instrument BI conectat: SELECT * FROM baza_date.nume_tabel.

Exemplu: Crearea unui tabel analitic gestionat în catalog
# Salvarea datelor optimizate în catalogul 'analytics':
df.write \
    .format("parquet") \
    .mode("overwrite") \
    .saveAsTable("analytics.vanzari_lunare")

# Interogare imediată prin Spark SQL:
spark.sql("SELECT an, SUM(valoare) FROM analytics.vanzari_lunare GROUP BY an").show()

Comunitate & Schimb de cunoștințe

Întrebări & Exemple de Cod: Salvarea Tabelelor Gestionate cu df.write.saveAsTable

Ai o nelămurire despre utilizarea comenzii Salvarea Tabelelor Gestionate cu df.write.saveAsTable sau ai descoperit un truc / fragment de cod util? Distribuie-l cu ceilalți programatori!

💬

Fii primul care pune o întrebare sau distribuie un fragment de cod / prompt!

Nu au fost adăugate încă întrebări sau exemple de cod pentru această pagină. Dacă ai întâlnit o problemă sau ai un snippet util, adaugă-l mai jos pentru a-i ajuta pe ceilalți.

Comunitate Adaugă o întrebare sau distribuie un cod

Moderare & Siguranță:

Pentru a menține calitatea și securitatea informațiilor, fiecare întrebare sau fragment de cod/prompt este analizat (manual sau prin moderare asistată de AI) înainte de publicare.