いつ

条件のリストを評価し、複数の可能な結果式のうちの 1 つを返します。otherwise()が呼び出されない場合、一致しない条件に対して None が返されます。Spark Connect をサポートします。

構文

Python

from pyspark.databricks.sql import functions as dbf

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

パラメーター

パラメーター	Type	説明
condition	pyspark.sql.Column	ブール列式。
value	すべて	リテラル値または列式。

戻り値

pyspark.sql.Column: when 式を表す列。

例

Python

from pyspark.databricks.sql import functions as dbf
df = spark.range(3)
df.select("*", dbf.when(df['id'] == 2, 3).otherwise(4)).show()

Output

+---+------------------------------------+
| id|CASE WHEN (id = 2) THEN 3 ELSE 4 END|
+---+------------------------------------+
|  0|                                   4|
|  1|                                   4|
|  2|                                   3|
+---+------------------------------------+