Как я могу использовать отделку в PySpark 2.x? - PullRequest
0 голосов
/ 01 октября 2018

Код:

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?Я не понимаю, почему это не работает, когда некоторые другие функции в том же пространстве имен работают отлично

...