SparkSQL中必须使用CaseClass

object Test1 {
  def main(args: Array[String]): Unit = {
    val spark = SparkSession.builder().master("local[*]").appName("test").getOrCreate()
    import spark.implicits._
    
    val rdd = spark.sparkContext.parallelize(Seq(new Time(1, 2)))
    val df = spark.createDataFrame(rdd, Time.getClass)
    df.printSchema() 
  		


    println("=========================")
    val df1 = spark.sparkContext.parallelize(Seq(Person("1", "chb"))).toDF()
    df1.printSchema()


  }
}


root 

============

root
---- id
-----name