toDF用法（隐式转化)

rdd的api并没有toDF（）方法，如果要使用必须的隐式转化
代码如下（Spark2.x）

val conf = new SparkConf().setMaster("local[2]")
val ss:SparkSession = SparkSession.builder().config(conf).getOrCreate()
val sparkContext=ss.sqlContext
import sparkContext.implicits._
XXX
xxxx
val rdd=ss.xxx
import sqlContext.implicits._val df = rdd.toDF()
val finalReusltRdd =rdd.map(line=>new finalVo(line._1,Day)).toDF().persist(StorageLevel.DISK_ONLY)

在object前面加上case class
代码如下

case class finalVo(uid:String,day:String)
object DmpPeopleTag_bak
{
XXXX
}