last_value

Vrátí poslední hodnotu col pro skupinu řádků. Vrátí poslední 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.last_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í poslední hodnoty bez ignorování hodnot null

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

+-------------+-------------+
|last_value(a)|last_value(b)|
+-------------+-------------+
|         NULL|            2|
+-------------+-------------+

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

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

+-------------+-------------+
|last_value(a)|last_value(b)|
+-------------+-------------+
|            b|            2|
+-------------+-------------+