floor(col)
Описание
Функция floor()
округляет число в меньшую сторону до ближайшего целого числа.
Параметры
col
: Column - числовой столбец для округления
Возвращаемое значение
Long - округленное в меньшую сторону целое число
Пример использования
from pyspark.sql.functions import floor
from pyspark.sql import SparkSession
# Создаем SparkSession
spark = SparkSession.builder.appName("floor_example").getOrCreate()
# Создаем DataFrame
data = [
("A", 3.14159),
("B", 2.71828),
("C", 1.41421),
("D", -1.5)
]
df = spark.createDataFrame(data, ["id", "value"])
# Округляем числа в меньшую сторону
result = df.select(
"id",
floor("value").alias("floor_value")
).show()
# Результат:
# +---+-----------+
# |id |floor_value|
# +---+-----------+
# |A |3 |
# |B |2 |
# |C |1 |
# |D |-2 |
# +---+-----------+