Quando

Valuta un elenco di condizioni e restituisce una tra più espressioni di risultato possibili. Se otherwise() non viene richiamato, None viene restituito per condizioni non corrispondenti. Supporta Spark Connect.

Sintassi

from pyspark.databricks.sql import functions as dbf

dbf.when(condition=<condition>, value=<value>)

Parametri

Parametro	TIPO	Description
condition	pyspark.sql.Column	Espressione column booleana.
value	Qualunque	Valore letterale o espressione Column.

Restituzioni

pyspark.sql.Column: colonna che rappresenta quando expression.

Esempi

from pyspark.databricks.sql import functions as dbf
df = spark.range(3)
df.select("*", dbf.when(df['id'] == 2, 3).otherwise(4)).show()

+---+------------------------------------+
| id|CASE WHEN (id = 2) THEN 3 ELSE 4 END|
+---+------------------------------------+
|  0|                                   4|
|  1|                                   4|
|  2|                                   3|
+---+------------------------------------+