草庐IT

roundCols

全部标签

scala - 如何优化 spark 函数以将 double 值舍入为 2 位小数?

下面是我的Spark函数,它很简单defdoubleToRound(df:DataFrame,roundColsList:Array[String]):DataFrame={vary:DataFrame=dffor(colDF这按预期工作,通过使给定DF的多个列的值将小数值四舍五入到2个位置。但是我循环遍历DataFramey直到Array[Sting].length()列。有更好的方法来完成上述操作吗?谢谢大家 最佳答案 您可以简单地使用select和map,如下例所示:importorg.apache.spark.sql.fun