一連の条件を評価して、考えられる結果式のうちの 1 つを返します。
otherwise()が呼び出されない場合は、一致しない条件に対して None が返されます。 Spark Connect をサポートします。
構文
from pyspark.databricks.sql import functions as dbf
dbf.when(condition=<condition>, value=<value>)
パラメーター
| パラメーター | タイプ | Description |
|---|---|---|
condition |
pyspark.sql.Column |
ブール値の列式。 |
value |
[任意] | リテラル値または Column 式。 |
返品ポリシー
pyspark.sql.Column: when 式を表す列。
例示
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|
+---+------------------------------------+