scala - 在Spark中舍入为Double

Question

我有一些Cassandra数据，其类型为double，需要在spark中将其四舍五入到小数点后一位。

问题是如何从cassandra中提取它，将其转换为小数，四舍五入到小数点后1位，然后写回到cassandra中的表中。我的舍入代码如下:

BigDecimal(number).setScale(1, BigDecimal.RoundingMode.DOWN).toDouble

如果输入的数字是小数，这会很好，但是我不知道在路由之前如何将 double 数转换为小数。四舍五入前，我的Double需要除以1000000。

例如，在将四舍五入为510.9之前，510999000将为510.990。

编辑:我可以使用以下命令来执行所需的操作。

BigDecimal(((number).toDouble) / 1000000).setScale(1, BigDecimal.RoundingMode.DOWN).toDouble

不知道这有多好，但它能起作用。

Answer 1

很好的答案的家伙。只是用别的方法做同样的事情

1. If using Spark DataFrame then ( x and y are DataFrames )
   import org.apache.spark.sql.functions.round 
   val y = x.withColumn("col1", round($"col1", 3))

2. val y = x.rdd.map( x => (x(0)*1000).round / 1000.toDouble )