我试过下面的代码
审判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)