Partilhar via


quando

Avalia uma lista de condições e retorna uma das várias expressões de resultado possíveis. Se otherwise() não for invocado, Nenhum é devolvido por condições não emparelhadas. Suporta o Spark Connect.

Sintaxe

from pyspark.databricks.sql import functions as dbf

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

Parâmetros

Parâmetro Tipo Description
condition pyspark.sql.Column Uma expressão coluna booleana.
value Qualquer Um valor literal, ou uma expressão Coluna.

Devoluções

pyspark.sql.Column: coluna representando quando expressão.

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