Ошибка Pyspark при передаче StructType в схему - PullRequest
1 голос
/ 13 марта 2020

Ошибка получения: TypeError: объект 'StructType' не может быть вызван при передаче StructType в метод схемы. Ниже приведен код:

final_schema = StructType([StructField("id", StringType(), True)])
dataframe = sc.read.text('/path').schema(final_schema)

Данные имеют строковый тип, как показано ниже:

id
AO_01
AO_02
AO_03

1 Ответ

1 голос
/ 13 марта 2020

Изменен вызов на sc.read.schema(final_schema).text('/path'), потому что text(...) вернет экземпляр кадра данных, и перед этим нужно будет установить схему.

...