when

Wertet eine Liste von Bedingungen aus und gibt einen von mehreren möglichen Ergebnisausdrücken zurück. Wenn otherwise() sie nicht aufgerufen wird, wird "None" für nicht übereinstimmende Bedingungen zurückgegeben. Unterstützt Spark Connect.

Syntax

from pyspark.databricks.sql import functions as dbf

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

Die Parameter

Parameter	Typ	Description
condition	pyspark.sql.Column	Ein boolescher Spaltenausdruck.
value	Beliebig	Ein Literalwert oder ein Column-Ausdruck.

Rückkehr

pyspark.sql.Column: Spalte, die beim Ausdruck darstellt.

Examples

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