Функция lit() отсутствует в PySpark?

Возможно, я ошибаюсь, но мне кажется, что в PySpark отсутствует функция pyspark.sql.functions.lit().

Впервые заметил, когда пытался импортировать. Я также проверил исходный код и не смог его найти. Просто хотел сначала проверить здесь, прав ли я, есть ли вообще ошибка.

Наконец, кто-нибудь знает, как я могу создать буквальный столбец из строкового ввода, желательно с помощью лямбда-функции?


python apache-spark pyspark apache-spark-sql apache-spark-2.0
person stackoverflowthebest    schedule 23.11.2016    source источник
comment
Я не выполнял код, потому что использую PyDev, и он выдал ошибку в строке импорта. Но теперь, когда вы спросили, мне пришло в голову, что это, вероятно, ошибка PyDev, и я просто выполнил код, и он сработал. Извините за ваше время. Просто, хотя: я проверил исходный код scala и заметил, что он просто создает новый объект Column с литеральным объектом. Итак, я попытался использовать python, используя Column(string), но, видимо, это не может быть строка. Я тоже новичок в python, так что не так ли я создал бы объект Column со строкой для инициализации?   -  person stackoverflowthebest    schedule 23.11.2016