Delen via


first_value

Retourneert de eerste waarde van col voor een groep rijen. Hiermee wordt de eerste niet-null-waarde geretourneerd die wordt weergegeven wanneer ignoreNulls deze is ingesteld op waar. Als alle waarden null zijn, wordt null geretourneerd.

Syntaxis

from pyspark.sql import functions as sf

sf.first_value(col, ignoreNulls=None)

Parameterwaarden

Kenmerk Typologie Description
col pyspark.sql.Column of str Doelkolom waaraan moet worden gewerkt.
ignoreNulls pyspark.sql.Column of bool, optioneel Als de eerste waarde null is, zoekt u naar de eerste niet-null-waarde.

Retouren

pyspark.sql.Column: een bepaalde waarde voor col een groep rijen.

Voorbeelden

Voorbeeld 1: Eerste waarde ophalen zonder null-waarden te negeren

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

Voorbeeld 2: Eerste waarde ophalen die null-waarden negeert

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