first_value

Vrátí první hodnotu col pro skupinu řádků. Vrátí první nenulovou hodnotu, která se zobrazí, když ignoreNulls je nastavena na hodnotu true. Pokud jsou všechny hodnoty null, vrátí se hodnota null.

Syntaxe

from pyspark.sql import functions as sf

sf.first_value(col, ignoreNulls=None)

Parametry

Parameter	Typ	Description
col	pyspark.sql.Column nebo str	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

Příklad 1: Získání první hodnoty bez ignorování hodnot null

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

+--------------+--------------+
|first_value(a)|first_value(b)|
+--------------+--------------+
|          NULL|             1|
+--------------+--------------+

Příklad 2: Získání první hodnoty, která ignoruje hodnoty null

from pyspark.sql import functions as sf
spark.createDataFrame(
    [(None, 1), ("a", 2), ("a", 3), ("b", 8), ("b", 2)], ["a", "b"]
).select(sf.first_value('a', True), sf.first_value('b', True)).show()

+--------------+--------------+
|first_value(a)|first_value(b)|
+--------------+--------------+
|             a|             1|
+--------------+--------------+