Pyspark regexp_replace 未定价预期结果

Question

专家，我正在尝试从 Pyspark 中的金额字段中删除前导 0 和 $ 符号并使用 regexp_replace 来代替它，但是我没有得到预期的结果-

>>> df = sqlContext.createDataFrame([('abcd','$000000000000432.14')], ['s', 'd'])
>>> df.select(expr('regexp_replace((regexp_replace(d, "(\$)", "")), "(^0+)", "")').alias("d")).show()
+-------------------+
|                  d|
+-------------------+
|$000000000000432.14|
+-------------------+

我在这里做错了什么？

谢谢

Answer 1

无需嵌套regexp_replace 调用：

from pyspark.sql import functions as F
df = spark.createDataFrame([('abcd','$000000000000432.14')], ['s', 'd'])
df.select(F.regexp_replace(F.col("d"), "\$0*", "").alias("d")).show()

打印

+-------+
|      d|
+-------+
|432.14 |
+-------+