Не удается импортировать искры SQL в Maven - PullRequest
0 голосов
/ 12 апреля 2019

Я пытаюсь импортировать 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

Добро пожаловать на сайт PullRequest, где вы можете задавать вопросы и получать ответы от других членов сообщества.
...