import spark.implicits._ 报红,无法导入


先给出错误的代码

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._ } 

原文出处:import spark.implicits._ 报红,无法导入 在这里插入图片描述


免责声明!

本站转载的文章为个人学习借鉴使用,本站对版权不负任何法律责任。如果侵犯了您的隐私权益,请联系本站邮箱yoyou2525@163.com删除。



 
粤ICP备18138465号  © 2018-2025 CODEPRJ.COM