计算条件列表，并返回多个可能的结果表达式之一。 如果未 otherwise() 调用，则针对不匹配的条件返回 None。 支持 Spark Connect。
Syntax
from pyspark.databricks.sql import functions as dbf
dbf.when(condition=<condition>, value=<value>)
参数
| 参数 | 类型 | Description |
|---|---|---|
condition |
pyspark.sql.Column |
布尔列表达式。 |
value |
任意 | 文本值或 Column 表达式。 |
退货
pyspark.sql.Column：表示何时表达式的列。
例子
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|
+---+------------------------------------+