eqNullSafe

Test równości, który jest bezpieczny dla wartości null.

Dodano w środowisku Databricks Runtime 11.0

Zmieniono w środowisku Databricks Runtime 13.0: obsługuje program Spark Connect.

Składnia

eqNullSafe(other)

Parametry

Parameter	Typ	Opis
other	Kolumna lub wartość	Wartość lub kolumna do porównania

Zwroty

Kolumna

Notatki

W przeciwieństwie do biblioteki Pandas, PySpark nie uwzględnia wartości NaN jako NULL. Aby uzyskać szczegółowe informacje, zobacz Semantyka sieci NaN .

Examples

from pyspark.sql import Row
df1 = spark.createDataFrame([
    Row(id=1, value='foo'),
    Row(id=2, value=None)
])
df1.select(
    df1['value'] == 'foo',
    df1['value'].eqNullSafe('foo'),
    df1['value'].eqNullSafe(None)
).show()

# +-------------+---------------+----------------+
# |(value = foo)|(value <=> foo)|(value <=> NULL)|
# +-------------+---------------+----------------+
# |         true|           true|           false|
# |         NULL|          false|            true|
# +-------------+---------------+----------------+