coalesce
Retourne la première colonne qui n'est pas NULL. Prend en charge Spark Connect.
Pour la fonction Databricks SQL correspondante, consultez la fonctioncoalesce.
Syntaxe
Python
from pyspark.sql import functions as dbf
dbf.coalesce(*cols)
parameter
parameter | Type | Description |
|---|---|---|
|
| Voici la liste des colonnes sur lesquelles travailler. |
Renvoie
pyspark.sql.Column: valeur de la première colonne qui n'est pas nulle.
Exemples
Python
from pyspark.sql import functions as dbf
df = spark.createDataFrame([(None, None), (1, None), (None, 2)], ("a", "b"))
df.select('*', dbf.coalesce("a", df["b"])).show()
Output
+----+----+--------------+
| a| b|coalesce(a, b)|
+----+----+--------------+
|NULL|NULL| NULL|
| 1|NULL| 1|
|NULL| 2| 2|
+----+----+--------------+