評估一份條件清單，並傳回多個可能的結果運算式之一。 若 otherwise() 未被調用，則因未匹配條件而返回無。 支援 Spark Connect。
語法
from pyspark.databricks.sql import functions as dbf
dbf.when(condition=<condition>, value=<value>)
參數
| 參數 | 類型 | Description |
|---|---|---|
condition |
pyspark.sql.Column |
一個布林欄位表達式。 |
value |
任意 | 一個字面值，或欄位表達式。 |
退貨
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|
+---+------------------------------------+