Pentru unirea textelor din coloane multiple, Spark pune la dispoziție două funcții native:
F.concat(): Unește valorile direct. Dacă oricare dintre coloane conțineNULL, rezultatul întregii concatenări devineNULL(conform regulilor SQL clasice).F.concat_ws(sep, *cols): Concat With Separator inserează delimitatorul dorit între elemente și, foarte important, ignoră automat valorile NULL, prevenind golirea rezultatului.
Exemplu: Compunerea numelui complet și a adresei poștale
from pyspark.sql import functions as F
df_formatat = df.withColumn(
"nume_complet",
F.concat_ws(" ", F.col("prenume"), F.col("nume"))
).withColumn(
"adresa_completa",
F.concat_ws(", ", F.col("strada"), F.col("oras"), F.col("tara"))
)
df_formatat.select("nume_complet", "adresa_completa").show(5, truncate=False)
Întrebări & Exemple de Cod:
Concatenarea Șirurilor cu F.concat și F.concat_wsAi o nelămurire despre utilizarea comenzii
Concatenarea Șirurilor cu F.concat și F.concat_wssau 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.