Spark SQL - 别名列名中带有逗号的列



我必须使用 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
"""
)

最新更新