Skip to content

nullif(expr1, expr2)

Описание

Функция nullif() возвращает NULL, если выражения равны, иначе возвращает первое выражение.

Параметры

  • expr1: Column - первое выражение
  • expr2: Column - второе выражение

Возвращаемое значение

Тип данных первого выражения

Пример использования

from pyspark.sql.functions import nullif, lit
from pyspark.sql import SparkSession

# Создаем SparkSession
spark = SparkSession.builder.appName("nullif_example").getOrCreate()

# Создаем DataFrame с данными
data = [
    (1, 1),
    (2, 3),
    (4, 4)
]
df = spark.createDataFrame(data, ["col1", "col2"])

# Возвращаем NULL для равных значений
result = df.select(
    nullif("col1", "col2").alias("result")
).show()

# Результат:
# +------+
# |result|
# +------+
# |null  |
# |2     |
# |null  |
# +------+

Примечания

  • Возвращает NULL, если выражения равны
  • Для проверки на NULL используйте isnull()
  • Для замены NULL на значение используйте nvl()
  • Для сравнения с учетом NULL используйте equal_null()