如何使用

Question

我试图下面码sparksql一个空间给一个别名

试验-1

..........

val df2=sqlContext.sql("select concat(' ',Id,LabelName) as 'first last' from p1 order by LabelName desc "); 

试验-2-

.........

val df2=sqlContext.sql("select concat(' ',Id,LabelName) from p1 order by LabelName desc "); 

val df3=df2.toDF("first last") 

试验-1抛出错误当我试图运行它.......但在试验-2它走的命令，但是当我以下动作

scala> df3.write.parquet("/prashanth/a1") 

Answer 1

1. 执行当SQL列包含引发错误SQL语句中的特殊字符，可以使用`，如`first last`。

2. 你不能在一个平面列中使用space。您可以重命名列或使用其他文件格式，例如csv。