Spark SQL - псевдоним столбца с запятой в имени столбца - PullRequest
0 голосов
/ 25 сентября 2019

Я должен хранить данные из временного представления в блоках данных, используя искровой SQL, в фрейм данных в формате с разделением запятыми.Таким образом, для нескольких столбцов во временном представлении в фрейме данных необходимо хранить только один столбец со всеми разделенными столбцами данных

Ниже приведен пример:

Temp View: temp_class
roll  name   subject
111   Ram    Maths

Dataframe: df

roll,name,subject
111,Ram,Maths

Below is the code without alias:

df= spark.sql("""
select concat(roll,',',name,',',subject) from temp_class
"""
)

Когда я пытаюсь добавить псевдоним, напримеробычным способом SQL (код ниже) кирпичи данных выдают ошибку - несоответствующий ввод "roll, name, subject", ожидающий

df= spark.sql("""
select concat(roll,',',name,',',subject) as "roll,name,subject" from temp_class
"""
)

Как я могу ввести псевдоним?

1 Ответ

0 голосов
/ 25 сентября 2019

Вам необходимо поместить псевдоним столбца в `` (серьезный акцент или обратный удар).

попробуйте это, оно должно работать для вас -

df= spark.sql("""
select concat(roll,',',name,',',subject) as `roll,name,subject` from temp_class
"""
)
...