quando

Avalia uma lista de condições e retorna uma entre várias expressões de resultado possíveis. Se otherwise() não for invocado, None será retornado para condições não correspondidas. Compatível com Spark Connect.

Sintaxe

Python

from pyspark.databricks.sql import functions as dbf

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

Parâmetros

Parâmetro	Tipo	Descrição
condition	pyspark.sql.Column	Uma expressão booleana de coluna.
value	Qualquer um	Um valor literal ou uma expressão de coluna.

Devoluções

pyspark.sql.Column: coluna que representa a expressão "quando".

Exemplos

Python

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

Output

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