when

Evalúa una lista de condiciones y devuelve una de las varias expresiones de resultado posibles. Si otherwise() no se invoca, none se devuelve para condiciones no coincidentes. Soporta Spark Connect.

Syntax

from pyspark.databricks.sql import functions as dbf

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

Parámetros

Parámetro	Tipo	Description
condition	pyspark.sql.Column	Expresión de columna booleana.
value	Cualquiera	Un valor literal o una expresión Column.

Devoluciones

pyspark.sql.Column: columna que representa cuándo expresión.

Examples

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|
+---+------------------------------------+