Kiedy

Oblicza listę warunków i zwraca jedno z wielu możliwych wyrażeń wyników. Jeśli otherwise() nie zostanie wywołana, brak zostanie zwrócony dla niepasowanych warunków. Obsługuje program Spark Connect.

Składnia

from pyspark.databricks.sql import functions as dbf

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

Parametry

Parameter	Typ	Description
condition	pyspark.sql.Column	Wyrażenie kolumny logicznej.
value	Jakikolwiek	Wartość literału lub wyrażenie kolumny.

Zwraca

pyspark.sql.Column: kolumna reprezentująca wyrażenie.

Przykłady

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