Поделиться через


Потолка

Вычисляет потолок заданного значения. Поддерживает Spark Connect.

Для соответствующей функции Databricks SQL смотрите функцию ceiling.

Синтаксис

from pyspark.databricks.sql import functions as dbf

dbf.ceiling(col=<col>, scale=<scale>)

Параметры

Параметр Тип Description
col pyspark.sql.Column or column name Целевой столбец или имя столбца для вычисления потолка.
scale pyspark.sql.Column or int Необязательный параметр для управления поведением округления.

Возвраты

pyspark.sql.Column: столбец для вычисляемых результатов.

Примеры

from pyspark.databricks.sql import functions as dbf
spark.range(1).select(dbf.ceiling(dbf.lit(-0.1))).show()
+-------------+
|ceiling(-0.1)|
+-------------+
|            0|
+-------------+

from pyspark.databricks.sql import functions as dbf
spark.range(1).select(dbf.ceiling(dbf.lit(-0.1), 1)).show()
+----------------+
|ceiling(-0.1, 1)|
+----------------+
|            -0.1|
+----------------+