rddbasics包
import org.apache.spark.sql.SparkSession
object CreatingSparkContextWithSparkSession {
def main(args: Array[String]): Unit = {
val sparkSession = SparkSession.builder()
.appName("Creating Spark context with spark session")
.getOrCreate()
val array = Array(1,2,3,4,5)
val arrayRDD = sparkSession.sparkContext.parallelize(array, 1)
arrayRDD.foreach(println)
我在eclipse中遇到了上述错误,有人能帮忙吗?
1条答案
按热度按时间khbbv19g1#
有问题吗
Scala version
. 类内路径scala版本2.12
&内部pom.xml scala版本2.11
在类路径中将scala版本从2.12更改为2.11或在pom.xml中,将scala版本2.11替换为2.12