-
- Downloads
[SPARK-2087] [SQL] Multiple thriftserver sessions with single HiveContext instance
Still, we keep only a single HiveContext within ThriftServer, and we also create a object called `SQLSession` for isolating the different user states. Developers can obtain/release a new user session via `openSession` and `closeSession`, and `SQLContext` and `HiveContext` will also provide a default session if no `openSession` called, for backward-compatibility. Author: Cheng Hao <hao.cheng@intel.com> Closes #4885 from chenghao-intel/multisessions_singlecontext and squashes the following commits: 1c47b2a [Cheng Hao] rename the tss => tlSession 815b27a [Cheng Hao] code style issue 57e3fa0 [Cheng Hao] openSession is not compatible between Hive0.12 & 0.13.1 4665b0d [Cheng Hao] thriftservice with single context
Showing
- sql/core/src/main/scala/org/apache/spark/sql/SQLContext.scala 41 additions, 2 deletions...core/src/main/scala/org/apache/spark/sql/SQLContext.scala
- sql/core/src/main/scala/org/apache/spark/sql/test/TestSQLContext.scala 13 additions, 4 deletions...main/scala/org/apache/spark/sql/test/TestSQLContext.scala
- sql/hive-thriftserver/src/main/scala/org/apache/spark/sql/hive/thriftserver/SparkSQLSessionManager.scala 0 additions, 56 deletions.../spark/sql/hive/thriftserver/SparkSQLSessionManager.scala
- sql/hive-thriftserver/src/test/scala/org/apache/spark/sql/hive/thriftserver/HiveThriftServer2Suites.scala 154 additions, 7 deletions...spark/sql/hive/thriftserver/HiveThriftServer2Suites.scala
- sql/hive-thriftserver/v0.12.0/src/main/scala/org/apache/spark/sql/hive/thriftserver/Shim12.scala 47 additions, 1 deletion...scala/org/apache/spark/sql/hive/thriftserver/Shim12.scala
- sql/hive-thriftserver/v0.13.1/src/main/scala/org/apache/spark/sql/hive/thriftserver/Shim13.scala 48 additions, 1 deletion...scala/org/apache/spark/sql/hive/thriftserver/Shim13.scala
- sql/hive/src/main/scala/org/apache/spark/sql/hive/HiveContext.scala 40 additions, 30 deletions...rc/main/scala/org/apache/spark/sql/hive/HiveContext.scala
- sql/hive/src/main/scala/org/apache/spark/sql/hive/test/TestHive.scala 10 additions, 4 deletions.../main/scala/org/apache/spark/sql/hive/test/TestHive.scala
Loading
Please register or sign in to comment