1. 程式人生 > >cannot resolve symbol toDF

cannot resolve symbol toDF

在寫sparksql的時候出現一個錯:

var sdf = new SimpleDateFormat("yyyy-MM-dd")
var sf = new SparkConf().setMaster("local").setAppName("bill")
var sc = new SparkContext(sf)
val sqlContext = new SQLContext(sc)
import sqlContext.implicits._
var personRDD = sc.textFile("").map(line=>{
  var log = line.split(" ")
  var birthday = sdf.parse(log(2))
  new Person(log(0).toInt,log(1).toString,birthday,log(3).toInt) //這裡的類 要用case修飾
})
var df = personRDD.toDF()//這裡會報cannot resolve symbol toDF

解決 這個問題: 

第一:匯入隱式裝換 

          import sqlContext.implicits._    

第二:檢查你即將呼叫toDF()方法的rdd 返回的 型別是否是用case 修飾,我這裡的Person類 要用case修飾