先給出錯誤的代碼
def main(args: Array[String]): Unit = { //Create SparkConf() And Set AppName SparkSession.builder() .appName("Spark Sql basic example") .config("spark.some.config.option", "some-value") .getOrCreate() //import implicit DF,DS import spark.implicits._ //這里的spark出現了紅色,無法導入 }
解決方法:給SparkSession.builder一個對應的變量值,這個變量值是spark。
這里的spark不是某個包下面的東西,而是我們SparkSession.builder()對應的變量值,下面是正確的寫法
def main(args: Array[String]): Unit = { //Create SparkConf() And Set AppName val spark= SparkSession.builder() .appName("Spark Sql basic example") .config("spark.some.config.option", "some-value") .getOrCreate() //import implicit DF,DS import spark.implicits._ }