Metoda withColumnRenamed() creează un nou DataFrame cu denumirea coloanei specificate actualizată. Este o transformare de metadate extrem de rapidă care nu declanșează calcule costisitoare sau deplasare de date pe rețea (shuffling).
Începând cu versiunile recente Spark, metoda withColumnsRenamed() permite redenumirea simultană a zeci de coloane prin transmiterea unui simplu dicționar Python {vechi: nou}.
Exemplu: Redenumirea individuală și în masă a coloanelor
# Redenumire individuală:
df_renumit = df.withColumnRenamed("usr_first_nm", "prenume")
# Redenumire multiplă fluentă prin dicționar:
redenumiri = {
"usr_last_nm": "nume_familie",
"created_ts": "data_inregistrarii",
"amt_total": "valoare_totala"
}
df_final = df_renumit.withColumnsRenamed(redenumiri)
df_final.printSchema()
Întrebări & Exemple de Cod:
Redenumirea Coloanelor cu df.withColumnRenamedAi o nelămurire despre utilizarea comenzii
Redenumirea Coloanelor cu df.withColumnRenamedsau 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.