小编Pra*_*Ach的帖子

如何在sparksql中给出带有空格的别名

我试过下面的代码

审判1

…………

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

审判-2

…………

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

val df3=df2.toDF("first last")
Run Code Online (Sandbox Code Playgroud)

当我尝试运行它时,Trial-1 抛出错误......但在 Trial-2 中,它正在接受命令,但当我执行以下操作时抛出错误

scala> df3.write.parquet("/prashanth/a1")
Run Code Online (Sandbox Code Playgroud)

scala apache-spark apache-spark-sql

1
推荐指数
1
解决办法
6933
查看次数

标签 统计

apache-spark ×1

apache-spark-sql ×1

scala ×1