如何使用

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。