无法将字符串转换为十进制,它返回null。
from pyspark.sql.types import DecimalType
df=spark.read("default.data_table")
df2=df.column("invoice_amount",df["invoice_amount"].cast('decimal(36,12)'))
//display(df)
display(df2)
发票金额为“15860461.48”(字符串)在表数据表中
如果我打印df-它显示发票金额为“15860461.48”,但是当我打印df2时,它显示空值
1条答案
按热度按时间ou6hu8tu1#
你用的是什么版本?在我的例子中,它在我使用spark3.0.1的地方运行得很好。