sparksql 之 struct使用demo

 val spark = SparkSession.builder()
            .master("local[*]")
            .appName("yy")
            .getOrCreate()
        val sc = spark.sparkContext
        spark.sparkContext.setLogLevel("WARN")
        // For implicit conversions like converting RDDs to Dataframes
        import spark.implicits._
        import org.apache.spark.sql.functions._ //解决:无法重载方法agg


        val data = Seq(
            Row(Row("a", "", "asd"), "23", "asf", "23434")
            , Row(Row("a", "", "asd"), "23", "asf", "23434")
            , Row(Row("a", "", "asd"), "23", "asf", "23434")
            , Row(Row("a", "", "asd"), "23", "asf", "23434")
            , Row(Row("a", "", "asd"), "23", "asf", "23434")
        )