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(

>>阅读原文<<