Я пытаюсь импортировать Spark SQL.Я не могу импортировать.Я не уверен насчет ошибки, которую я совершаю.Я только начинающий ученик.
package MySource
import java.sql.{DriverManager, ResultSet}
import org.apache.spark.sql.SparkSession
import java.util.Properties
object MyCalc {
def main(args: Array[String]): Unit = {
println("This is my first Spark")
//val sqlContext = new org.apache.spark.sql.SQLContext(sc)
val spark = SparkSession
.builder()
.appName("SparkSQL")
//.master("YARN")
.master("local[*]")
//.enableHiveSupport()
//.config("spark.sql.warehouse.dir","file:///c:/temp")
.getOrCreate()
import spark.sqlContext.implicits._
}
}
Ошибка: (3, 8) объект SparkSession не является членом пакета org.apache.spark.sql
import org.apache.spark.sql.SparkSession
Ошибка: (15, 17) не найдено: значение SparkSession
val spark = SparkSession