Înlocuirea Valorilor Țintă cu df.na.replace în Apache Spark & PySpark

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

Maparea și substituirea valorilor specifice dintr-un DataFrame folosind un dicționar de echivalențe.

Sintaxă
df.na.replace(to_replace, value=None, subset=None)

Metoda df.na.replace() permite căutarea și înlocuirea rapidă a unor valori țintă specificate din coloane, fiind ideală pentru standardizarea etichetelor sau a codurilor de stare (ex. transformarea abrevierilor de țară sau corectarea greșelilor tipografice cunoscute).

Se poate transmite fie o listă de valori vechi și una de valori noi, fie un dicționar Python intuitiv {valoare_veche: valoare_noua}.

Exemplu: Standardizarea stărilor de comandă
mapare_stari = {
    "in_progress": "PROCESARE",
    "pend": "IN_ASTEPTARE",
    "canceled": "ANULAT"
}

df_standardizat = df_comenzi.na.replace(mapare_stari, subset=["status"])
df_standardizat.select("id", "status").show(5)

Comunitate & Schimb de cunoștințe

Întrebări & Exemple de Cod: Înlocuirea Valorilor Țintă cu df.na.replace

Ai o nelămurire despre utilizarea comenzii Înlocuirea Valorilor Țintă cu df.na.replace 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.