sim*_*ing 6 apache-spark-sql pyspark
代码是:
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
trimPySpark 2.x 中已弃用吗?我不明白为什么它不起作用,而同一命名空间中的其他一些函数却工作得很好
| 归档时间: | 
 | 
| 查看次数: | 3382 次 | 
| 最近记录: |