Delta Lake este un strat de stocare open-source construit peste fișiere Parquet și un jurnal tranzacțional securizat (_delta_log). Acesta aduce garanții ACID la nivel de tabel pe stocarea în cloud (S3, ADLS, GCS), eliminând riscurile de corupere a datelor la scrieri parțiale sau eșecuri ale nodurilor.
Delta oferă capabilități unice de Time Travel (interogarea stării tabelei la o versiune istorică sau dată anterioară) și operațiuni eficiente de MERGE INTO (Upsert).
Exemplu: Scriere Delta și interogare istorică (Time Travel)
# Salvarea datelor în format Delta cu suprascriere sigură:
df.write.format("delta").mode("overwrite").save("/mnt/lakehouse/clienti")
# Citirea stării tabelei de acum 7 zile (Time Travel după versiune sau timestamp):
df_istoric = spark.read.format("delta") \
.option("versionAsOf", 2) \
.load("/mnt/lakehouse/clienti")
df_istoric.show(5)
Întrebări & Exemple de Cod:
Tranzacții ACID și Stocare cu Formatul Delta LakeAi o nelămurire despre utilizarea comenzii
Tranzacții ACID și Stocare cu Formatul Delta Lakesau 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.