pyspark - 如何在 PySpark 2.x 中使用修剪？

Question

代码是：

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 中被弃用了吗？我不明白为什么它不工作，当同一个命名空间中的其他一些函数工作得很好时

标签： pysparkpyspark-sql

Answer 1

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