如何在 PySpark 2.x 中使用修剪? [英] How do I use trim in PySpark 2.x?

问题描述

代码是:

from pyspark.sql import functions as F
df = df.select(F.trim("MyColumn"))

错误是:

Py4JError: An error occurred while calling z:org.apache.spark.sql.functions.trim. Trace:
py4j.Py4JException: Method trim([class java.lang.String]) does not exist

trim 在 PySpark 2.x 中被弃用了吗?我不明白为什么它不起作用，当同一个命名空间中的其他一些函数工作得很好

Is trim deprecated in PySpark 2.x? I don't understand why it's not working, when some other functions in the same namespace work perfectly fine

推荐答案

df = df.select(F.trim(F.col("MyColumn")))

df = df.select(F.trim(F.col("MyColumn")))

这篇关于如何在 PySpark 2.x 中使用修剪?的文章就介绍到这了，希望我们推荐的答案对大家有所帮助，也希望大家多多支持IT屋！