シーリング
指定された値の上限をコンピュートします。 Spark Connect をサポートします。
対応する Databricks SQL 関数については、 ceiling関数を参照してください。
構文
Python
from pyspark.sql import functions as dbf
dbf.ceiling(col=<col>, scale=<scale>)
パラメーター
パラメーター | Type | 説明 |
|---|---|---|
|
| ターゲットカラムまたは天井をコンピュートする列の名前。 |
|
| 丸め動作を制御するオプションのパラメーター。 |
戻り値
pyspark.sql.Column: コンピュート結果の列。
例
Python
from pyspark.sql import functions as dbf
spark.range(1).select(dbf.ceiling(dbf.lit(-0.1))).show()
Output
+-------------+
|ceiling(-0.1)|
+-------------+
| 0|
+-------------+
Python
from pyspark.sql import functions as dbf
spark.range(1).select(dbf.ceiling(dbf.lit(-0.1), 1)).show()
Output
+----------------+
|ceiling(-0.1, 1)|
+----------------+
| -0.1|
+----------------+