Funcția pyspark.sql.functions.when() permite evaluarea condițiilor logice booleene pe rândurile unui DataFrame, returnând valori diferite în funcție de rezultatul verificării. Prin înlănțuirea metodelor .when() și încheierea cu .otherwise(), se obține echivalentul complet al instrucțiunilor CASE WHEN ... THEN ... ELSE ... END din SQL.
Exemplu: Segmentarea clienților pe niveluri de loialitate
from pyspark.sql import functions as F
df_segmentat = df_clienti.withColumn(
"segment_client",
F.when(F.col("puncte") >= 1000, "PLATINUM")
.when((F.col("puncte") >= 500) & (F.col("puncte") < 1000), "GOLD")
.when(F.col("puncte") >= 100, "SILVER")
.otherwise("STANDARD")
)
df_segmentat.select("nume", "puncte", "segment_client").show(5)
Întrebări & Exemple de Cod:
Logică Condițională cu F.when().otherwise()Ai o nelămurire despre utilizarea comenzii
Logică Condițională cu F.when().otherwise()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.