Funcția pyspark.sql.functions.coalesce() evaluează argumentele transmise în ordine și returnează prima valoare care nu este NULL. Este tehnica clasică pentru stabilirea unei valori de rezervă (fallback) între mai multe coloane posibile.
Notă: A nu se confunda cu metoda de re-partiționare a DataFrame-ului df.coalesce(n); funcția F.coalesce() operează strict la nivel de expresie pe coloane.
Exemplu: Prioritizarea metodelor de contact ale unui utilizator
from pyspark.sql import functions as F
# Prioritate: Telefon mobil -> Telefon fix -> Email -> Mesaj implicit
df_contact = df.withColumn(
"contact_principal",
F.coalesce(
F.col("telefon_mobil"),
F.col("telefon_fix"),
F.col("email"),
F.lit("Fara date de contact")
)
)
df_contact.select("nume", "contact_principal").show(5)
Întrebări & Exemple de Cod:
Selectarea Primei Valori Valide cu F.coalesceAi o nelămurire despre utilizarea comenzii
Selectarea Primei Valori Valide cu F.coalescesau 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.