aboutsummaryrefslogtreecommitdiff
path: root/sql/core/src/main/scala/org
diff options
context:
space:
mode:
Diffstat (limited to 'sql/core/src/main/scala/org')
-rw-r--r--sql/core/src/main/scala/org/apache/spark/sql/SparkSession.scala8
1 files changed, 7 insertions, 1 deletions
diff --git a/sql/core/src/main/scala/org/apache/spark/sql/SparkSession.scala b/sql/core/src/main/scala/org/apache/spark/sql/SparkSession.scala
index 5c8742d1d8..131f28f98b 100644
--- a/sql/core/src/main/scala/org/apache/spark/sql/SparkSession.scala
+++ b/sql/core/src/main/scala/org/apache/spark/sql/SparkSession.scala
@@ -905,7 +905,7 @@ class SparkSession private(
}
-private object SparkSession {
+object SparkSession {
private def sharedStateClassName(conf: SparkConf): String = {
conf.get(CATALOG_IMPLEMENTATION) match {
@@ -938,4 +938,10 @@ private object SparkSession {
}
}
+ // TODO: do we want to expose this?
+ def withHiveSupport(sc: SparkContext): SparkSession = {
+ sc.conf.set(CATALOG_IMPLEMENTATION.key, "hive")
+ new SparkSession(sc)
+ }
+
}