scala – Spark SQL更改格式的数字

发布时间：2020-12-16 19:18:44 所属栏目：安全来源：网络整理

导读：show命令spark后打印以下内容： +-----------------------+---------------------------+|NameColumn |NumberColumn |+-----------------------+---------------------------+|name |4.3E-5 |+-----------------------+---------------------------+ 有没有

show命令spark后打印以下内容：

+-----------------------+---------------------------+
|NameColumn             |NumberColumn               |
+-----------------------+---------------------------+
|name                   |4.3E-5                     |
+-----------------------+---------------------------+

有没有办法将NumberColumn格式更改为0.000043？

解决方法

你可以使用format_number function作为

import org.apache.spark.sql.functions.format_number
df.withColumn("NumberColumn",format_number($"NumberColumn",5))

这里5是你想要显示的小数位

正如您在上面的链接中看到的那样,format_number函数返回一个字符串列

format_number(Column x,int d)
Formats numeric column x to a format like ‘#,###,###.##’,rounded to d decimal places,and returns the result as a string column.

如果您不需要,可以调用定义为的regexp_replace函数

regexp_replace(Column e,String pattern,String replacement)
Replace all substrings of the specified string value that match regexp with rep.

并用它作为

import org.apache.spark.sql.functions.regexp_replace
df.withColumn("NumberColumn",regexp_replace(format_number($"NumberColumn",5),",""))

因此,对于大数字,应删除逗号(,).

（编辑：李大同）

【声明】本站内容均来自网络，其相关言论仅代表作者个人观点，不代表本站立场。若无意侵犯到您的权利，请及时与联系站长删除相关内容!