解決value toDF is not a member of org.apache.spark.rdd.RDD (spark2.1 )

解決上述辦法有兩點：

　　1、兩個import 需要放在 hiveCtx之后。

val hiveCtx: SparkSession = SparkSession.builder.config(conf).enableHiveSupport().getOrCreate()
import hiveCtx.sql
import hiveCtx.implicits._

　　2、case class 類(param1：type1 )需要放在函數外面，作為成員變量。