我必须使用 spark 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
"""
)
如何输入别名?
您需要将列别名放在"(重音符号或反引号(中。
试试这个,它应该对你有用——
df= spark.sql("""
select concat(roll,',',name,',',subject) as `roll,name,subject` from temp_class
"""
)