Как я могу передать список столбцов для выбора в pyspark dataframe? - PullRequest
1 голос
/ 20 марта 2020

У меня есть имена столбцов списка.

columns = ['home','house','office','work']

, и я хотел бы передать значения этого списка в качестве имени столбцов в кадре данных "select".

Я пробовал это ...

df_tables_full = df_tables_full.select('time_event','kind','schema','table',columns)

но я получил ошибку ниже ..

TypeError: Invalid argument, not a string or column: ['home', 'house', 'office',
'work'] of type <class 'list'>. For column literals, use 'lit', 'array', 'struct' 
or 'create_map' function.

Можете ли вы иметь какие-либо идеи? Спасибо, ребята!

1 Ответ

2 голосов
/ 20 марта 2020

Используйте * перед columns для удаления списка столбцов и используйте в .select.

columns = ['home','house','office','work']

#select the list of columns
df_tables_full.select('time_event','kind','schema','table',*columns).show()

df_tables_full = df_tables_full.select('time_event','kind','schema','table',*columns)
Добро пожаловать на сайт PullRequest, где вы можете задавать вопросы и получать ответы от других членов сообщества.
...