PySpark Как анализировать и получать имена полей из объекта StructType схемы Dataframe - PullRequest
0 голосов
/ 24 октября 2018

Я создал Dataframe из таблицы Hive и хочу получить имена полей / столбцов.

>>>a=df.schema
>>>a
StructType(List(StructField(empid, IntegerType, true), StructField(empname,StringType, true)))

Как получить имена полей (empid, empname) из этого объекта.

1 Ответ

0 голосов
/ 24 октября 2018

Использование pyspark.sql.types.StructType.fieldnames:

fieldNames()

Возвращает все имена полей в списке.

>>> struct = StructType([StructField("f1", StringType(), True)])
>>> struct.fieldNames()
['f1']
...