last_value

Bir satır grubu için değerinin son değerini col döndürür. True olarak ayarlandığında gördüğü ignoreNulls son null olmayan değeri döndürür. Tüm değerler null ise null döndürülür.

Sözdizimi

from pyspark.sql import functions as sf

sf.last_value(col, ignoreNulls=None)

Parametreler

Parametre	Türü	Description
col	pyspark.sql.Column veya str	Üzerinde çalışacak hedef sütun.
ignoreNulls	pyspark.sql.Column veya bool, isteğe bağlı	İlk değer null ise, ilk null olmayan değeri arayın.

İade

pyspark.sql.Column: bir satır grubu için değerinin değeri col .

Örnekler

Örnek 1: Null değerleri yoksaymadan son değeri alma

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

Örnek 2: Null değerleri yoksayarak son değeri alma

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