如何导入 sparksession

Question

如何创建 sparksession？

scala> import org.apache.spark.SparkConf
import org.apache.spark.SparkConf

scala>    import org.apache.spark.SparkContext 
import org.apache.spark.SparkContext

scala> val conf = SparkSession.builder.master("local").appName("testing").enableHiveSupport().getOrCreate()  

<console>:27: error: not found: value SparkSession
         val conf = SparkSession.builder.master("local").appName("testing").enableHiveSupport().getOrCreate()

Answer 1

SparkSession 在 Spark 2.x 中可用

import org.apache.spark.sql.SparkSession

尽管当您启动 Spark shell 时 SparkSession 已经可以作为spark变量使用。