any_value

Vrátí nějakou hodnotu sloupce pro skupinu řádků.

Syntaxe

from pyspark.sql import functions as sf

sf.any_value(col, ignoreNulls=None)

Parametry

Parameter Typ Description
col pyspark.sql.Column nebo název sloupce Cílový sloupec, na který chcete pracovat.
ignoreNulls pyspark.sql.Column nebo bool, volitelné Pokud je první hodnota null, vyhledejte první hodnotu, která není null.

Návraty

pyspark.sql.Column: určitá hodnota col pro skupinu řádků.

Examples

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()
+-------------+-------------+
|any_value(c1)|any_value(c2)|
+-------------+-------------+
|         NULL|            1|
+-------------+-------------+
df.select(sf.any_value('c1', True), sf.any_value('c2', True)).show()
+-------------+-------------+
|any_value(c1)|any_value(c2)|
+-------------+-------------+
|            a|            1|
+-------------+-------------+