=(left, right)
Описание
Оператор =
проверяет равенство двух значений.
Параметры
left
: Column - левый операндright
: Column - правый операнд
Возвращаемое значение
Column - boolean значение (true, если значения равны, false в противном случае)
Пример использования
from pyspark.sql.functions import col, lit
from pyspark.sql import SparkSession
# Создаем SparkSession
spark = SparkSession.builder.appName("equality_example").getOrCreate()
# Создаем DataFrame с данными
data = [
(1, 1),
(2, 3),
(4, 4),
(5, None)
]
df = spark.createDataFrame(data, ["a", "b"])
# Проверяем равенство значений
result = df.withColumn(
"a_equals_b",
col("a") == col("b")
).withColumn(
"a_equals_4",
col("a") == lit(4)
)
result.show(truncate=False)
# Результат:
# +---+----+----------+----------+
# |a |b |a_equals_b|a_equals_4|
# +---+----+----------+----------+
# |1 |1 |true |false |
# |2 |3 |false |false |
# |4 |4 |true |true |
# |5 |null|null |false |
# +---+----+----------+----------+
Примечания
- Возвращает NULL, если любой из операндов NULL
- Сравнивает значения с учетом их типов
- Полезно для:
- Фильтрации данных
- Сравнения значений
- Условных выражений
- Связанные операторы:
<>
- неравенство<=>
- равенство с учетом NULLequal_null()
- специальное сравнение с NULL