eqNullSafe

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

Databricks Runtime 11.0 で追加されました

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

構文

eqNullSafe(other)

パラメーター

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

返品

コラム

メモ

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

例示

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