조건 목록을 평가하고 가능한 여러 결과 식 중 하나를 반환합니다.
otherwise() 호출되지 않으면 일치하지 않는 조건에 대해 None이 반환됩니다. Spark Connect를 지원합니다.
문법
from pyspark.databricks.sql import functions as dbf
dbf.when(condition=<condition>, value=<value>)
매개 변수
| 매개 변수 | 유형 | Description |
|---|---|---|
condition |
pyspark.sql.Column |
부울 열 식입니다. |
value |
어느 것이든 | 리터럴 값 또는 열 식입니다. |
Returns
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|
+---+------------------------------------+