如何使用 Pyspark 将字符串列转换为十进制列

Question

我有一个带有字符串列的数据框，我需要将其转换为十进制。以下是数据示例：

我尝试了以下方法：

df_line_items = df_line_items.withColumn("product_sold_price", df_line_items.product_sold_price.cast("decimal(3,2)"))

，但它只是使所有值都为空。感谢任何想法。谢谢

Answer 1

不要使用小数，而是尝试使用 Double - 这应该可以解决您的所有问题。

df_line_items = df_line_items.withColumn("product_sold_price", df_line_items.product_sold_price.cast("double"))

Answer 2

这是因为当您的数据超出该范围时，decimal(3,2) 只能允许 3 位精度和小数点后 2 位数字（范围 -9.99 到 9.99）。从上图中，至少你需要将它们转换为decimal(5,2)。