mikor

Kiértékeli a feltételek listáját, és több lehetséges eredménykifejezés egyikét adja vissza. Ha otherwise() a meghívás nem történik meg, a None függvény a nem egyező feltételekhez ad vissza értéket. Támogatja a Spark Connectet.

Szemantika

from pyspark.databricks.sql import functions as dbf

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

Paraméterek

Paraméter	Típus	Description
condition	pyspark.sql.Column	Logikai oszlopkifejezés.
value	Bármely	Literális érték vagy oszlopkifejezés.

Visszatérítések

pyspark.sql.Column: a kifejezéseket ábrázoló oszlop.

Példák

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|
+---+------------------------------------+