when

Évalue une liste de conditions et retourne une expression de résultat parmi plusieurs possibilités. S’il otherwise() n’est pas appelé, aucun n’est retourné pour les conditions sans correspondance. Prend en charge Spark Connect.

Syntaxe

from pyspark.databricks.sql import functions as dbf

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

Paramètres

Paramètre	Type	Descriptif
condition	pyspark.sql.Column	Expression de colonne booléenne.
value	N'importe lequel	Valeur littérale ou expression column.

Retours

pyspark.sql.Column: colonne représentant lors de l’expression.

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