last_value

Mengembalikan nilai col terakhir untuk sekelompok baris. Ini akan mengembalikan nilai non-null terakhir yang dilihatnya ketika ignoreNulls diatur ke true. Jika semua nilai null, maka null dikembalikan.

Syntax

from pyspark.sql import functions as sf

sf.last_value(col, ignoreNulls=None)

Parameter-parameternya

Pengaturan	Tipe	Description
col	pyspark.sql.Column atau str	Kolom target untuk dikerjakan.
ignoreNulls	pyspark.sql.Column atau bool, opsional	Jika nilai pertama null, maka cari nilai non-null pertama.

Pengembalian Barang

pyspark.sql.Column: beberapa nilai col untuk sekelompok baris.

Examples

Contoh 1: Dapatkan nilai terakhir tanpa mengabaikan 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|
+-------------+-------------+

Contoh 2: Dapatkan nilai terakhir yang mengabaikan 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|
+-------------+-------------+