any_value

Renvoie une certaine valeur de col pour un groupe de lignes.

Syntaxe

Python

from pyspark.sql import functions as sf

sf.any_value(col, ignoreNulls=None)

parameter

parameter	Type	Description
col	pyspark.sql.Column ou nom de colonne	Colonne cible sur laquelle travailler.
ignoreNulls	pyspark.sql.Column ou booléen, facultatif	Si la première valeur est nulle, alors recherchez la première valeur non nulle.

parameter	Type	Description
col	pyspark.sql.Column ou nom de colonne	Colonne cible sur laquelle travailler.
ignoreNulls	pyspark.sql.Column ou booléen, facultatif	Si la première valeur est nulle, alors recherchez la première valeur non nulle.

Renvoie

pyspark.sql.Column : une certaine valeur de col pour un groupe de lignes.

Exemples

Python

from pyspark.sql import functions as sf
df = spark.createDataFrame(
    [(None, 1), ("a", 2), ("a", 3), ("b", 8), ("b", 2)], ["c1", "c2"])
df.select(sf.any_value('c1'), sf.any_value('c2')).show()

Output

+-------------+-------------+
|any_value(c1)|any_value(c2)|
+-------------+-------------+
|         NULL|            1|
+-------------+-------------+

Python

df.select(sf.any_value('c1', True), sf.any_value('c2', True)).show()

Output

+-------------+-------------+
|any_value(c1)|any_value(c2)|
+-------------+-------------+
|            a|            1|
+-------------+-------------+