any_value

Zwraca pewną wartość kolumny dla grupy wierszy.

Składnia

from pyspark.sql import functions as sf

sf.any_value(col, ignoreNulls=None)

Parametry

Parameter	Typ	Description
col	pyspark.sql.Column lub nazwa kolumny	Kolumna docelowa do pracy.
ignoreNulls	pyspark.sql.Column lub wartość logiczna, opcjonalnie	Jeśli pierwsza wartość ma wartość null, poszukaj pierwszej wartości innej niż null.

Zwraca

pyspark.sql.Column: niektóre wartości col dla grupy wierszy.

Przykłady

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