nanvl

Vrátí col1, pokud není NaN, nebo col2, pokud col1 je NaN. Oba vstupy by měly být sloupce s plovoucí desetinou čárkou (DoubleType nebo FloatType). Podporuje Spark Connect.

Odpovídající funkci SQL Databricks vizte funkcenanvl.

Syntaxe

from pyspark.sql import functions as dbf

dbf.nanvl(col1=<col1>, col2=<col2>)

Parametry

Parameter	Typ	Description
col1	pyspark.sql.Column nebo str	První sloupec, který chcete zkontrolovat.
col2	pyspark.sql.Column nebo str	Druhý sloupec, který se má vrátit, pokud je první naN.

Návraty

pyspark.sql.Column: hodnota z prvního sloupce nebo sekundy, pokud je první naN .

Examples

from pyspark.sql import functions as dbf
df = spark.createDataFrame([(1.0, float('nan')), (float('nan'), 2.0)], ("a", "b"))
df.select("*", dbf.nanvl("a", "b"), dbf.nanvl(df.a, df.b)).show()

+---+---+-----------+-----------+
|  a|  b|nanvl(a, b)|nanvl(a, b)|
+---+---+-----------+-----------+
|1.0|NaN|        1.0|        1.0|
|NaN|2.0|        2.0|        2.0|
+---+---+-----------+-----------+