spark rdd转dataframe的两种方式

方式1:

使用隐式转换

 case class Dika(skuId: Int,skudesc:String, listId: Int, listDesc:String)

 import hiveContext.implicits._

    val p = sc.parallelize(Seq(new Dika(1,"miao",1,"shu"))).toDF()

    p.show(1)

    p.printSchema()

方式2:

使用StructType

    val schema = StructType(

      Seq(

        StructField("skuId",IntegerType,true),

        StructField("skudesc",StringType,true),

        StructField("listId",IntegerType,true),

        StructField("listDesc",StringType,true)

      )

    )

    val p2: RDD[Row] = sc.parallelize(Seq(Row(1,"222",3,"666")))

    val df2: SchemaRDD = hiveContext.createDataFrame(p2,schema)

    df2.printSchema()

    df2.show(1)