eqNullSafe

Teste de igualdade que é seguro para valores nulos.

Adicionado no Databricks Runtime 11.0

Alterado no Databricks Runtime 13.0 : Suporte ao Spark Connect.

Sintaxe

Python

eqNullSafe(other)

Parâmetros

Parâmetro	Tipo	Descrição
other	Coluna ou valor	Um valor ou coluna para comparar.

Parâmetro	Tipo	Descrição
other	Coluna ou valor	Um valor ou coluna para comparar.

Devoluções

Coluna

Notas

Diferentemente do Pandas, o PySpark não considera valores NaN como NULL. Consulte a Semântica NaN para obter detalhes.

Exemplos

Python

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()

Output

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