Code is:
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
Is trim
PySpark 2.x 中已弃用?我不明白为什么它不起作用,而同一命名空间中的其他一些函数却工作得很好
df = df.select(F.trim(F.col("MyColumn")))
本文内容由网友自发贡献,版权归原作者所有,本站不承担相应法律责任。如您发现有涉嫌抄袭侵权的内容,请联系:hwhale#tublm.com(使用前将#替换为@)