先给出错误的代码
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._ }