negative(col)
Описание
Функция negative()
возвращает отрицательное значение числа (эквивалентно умножению на -1).
Параметры
col
: Column - числовой столбец
Возвращаемое значение
Column - отрицательное значение числа
Пример использования
from pyspark.sql.functions import negative, lit
from pyspark.sql import SparkSession
# Создаем SparkSession
spark = SparkSession.builder.appName("negative_example").getOrCreate()
# Создаем DataFrame с числами
data = [
(-5,),
(0,),
(5,)
]
df = spark.createDataFrame(data, ["number"])
# Применяем функцию negative
df = df.withColumn("negative_value", negative("number"))
df.show(truncate=False)
# Результат:
# +------+--------------+
# |number|negative_value|
# +------+--------------+
# |-5 |5 |
# |0 |0 |
# |5 |-5 |
# +------+--------------+
Примечания
- Возвращает NULL, если входное значение NULL
- Эквивалентна умножению на -1
- Для получения положительного значения используйте
positive()
- Для изменения знака числа используйте
negate()
- Полезно для:
- Инвертирования значений
- Изменения направления величин
- Работы с противоположными значениями