eqNullSafe

null値に対しても安全な等価性テスト。

Databricks Runtime 11.0で追加されました

Databricks Runtime 13.0 での変更点 : Spark Connect をサポートしました。

構文

Python

eqNullSafe(other)

パラメーター

パラメーター	Type	説明
other	列または値	比較する値または列

戻り値

列

注意

Pandasとは異なり、PySparkはNaN値をNULLとはみなしません。詳細については、 NaNのセマンティクスを参照してください。

例

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