我这里SparkSession.builder()的变量名是session,下面导入的时候就需要导入session.implicits._
import org.apache.spark.rdd.RDD
import org.apache.spark.sql.{Dataframe, SparkSession}
object Practice {
def main(args: Array[String]): Unit = {
//我这里的变量名是session,下面导入的时候就需要导入session.implicits._
val session: SparkSession = SparkSession.builder().appName("Test").master("local").getOrCreate()
val RDD: RDD[Int] = session.sparkContext.makeRDD(List(1, 2, 3))
//RDD转Dataframe
import session.implicits._
RDD.toDF()
}
}



