小编dav*_*ave的帖子

在pyspark中使用round函数时遇到一些麻烦 - 我有下面的代码块,我试图将new_bid列舍入到2位小数,然后重命名列bid- 我正在导入pyspark.sql.functions AS func以供参考,并使用其中round包含的功能:

output = output.select(col("ad").alias("ad_id"),
                       col("part").alias("part_id"),
                       func.round(col("new_bid"), 2).alias("bid"))

new_bid这里的列是float类型 - 结果数据框没有新命名的bid列舍入到我想要的2位小数,而是仍然是8或9位小数.

我尝试了各种各样的东西,但似乎无法让结果数据框具有舍入值 - 任何指针都将非常感激!谢谢!