在代码中导入spark的引入转换失败
import sparkSession.implicits._
sparkSession飘红,无法正确导入
解决办法?
我们需要将 创建的SparkContext或者SparkSession对象设置为spark
例如:
val spark = SparkSession.builder().appName("hello").master("local[2]").getOrCreate()
val oriData = ss.sparkContext.textFile("D://ML/1.txt")
import spark.implicits._
然后就发现可以引用了