Skip to content

ceiling(col)

Описание

Функция ceiling() округляет число вверх до ближайшего целого числа.

Параметры

  • col: Column - число для округления

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

Column - округленное вверх целое число

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

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

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

# Создаем DataFrame с числами
data = [
    (1.0,),     # 1.0 -> 1
    (1.2,),     # 1.2 -> 2
    (1.5,),     # 1.5 -> 2
    (1.9,),     # 1.9 -> 2
    (-1.2,),    # -1.2 -> -1
    (-1.5,),    # -1.5 -> -1
    (-1.9,)     # -1.9 -> -1
]
df = spark.createDataFrame(data, ["number"])

# Округляем числа вверх
df = df.withColumn("ceiling", ceiling("number"))
df.show(truncate=False)

# Результат:
# +------+-------+
# |number|ceiling|
# +------+-------+
# |1.0   |1      |
# |1.2   |2      |
# |1.5   |2      |
# |1.9   |2      |
# |-1.2  |-1     |
# |-1.5  |-1     |
# |-1.9  |-1     |
# +------+-------+

Примечания

  • Возвращает NULL, если входное значение NULL
  • Работает с положительными и отрицательными числами
  • Для отрицательных чисел округляет в сторону нуля
  • Эквивалентна функции ceil()
  • Полезно для:
  • Вычисления минимального количества элементов
  • Округления размеров вверх
  • Определения границ интервалов
  • Связанные функции:
  • floor() - округление вниз
  • round() - округление до указанного количества знаков
  • trunc() - отбрасывание дробной части