Spark SQL--執行模式

DSL風格語法sql scala> val peopleDF = rdd.map{x => val strs=x.split(",");People(strs(0),strs(1).trim.toInt)}.toDF peopleDF: org.apache.spark.sql.DataFrame = [name: string, age: int] scala> peopleDF.select(

>>阅读原文<<