Skip to content

Commit 6593842

Browse files
committed
Fixed style issues for [SPARK-6909][SQL] Remove Hive Shim code.
1 parent 0526fea commit 6593842

File tree

2 files changed

+11
-8
lines changed

2 files changed

+11
-8
lines changed

sql/hive-thriftserver/src/main/scala/org/apache/spark/sql/hive/thriftserver/HiveThriftServer2.scala

Lines changed: 3 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -17,6 +17,9 @@
1717

1818
package org.apache.spark.sql.hive.thriftserver
1919

20+
import scala.collection.mutable
21+
import scala.collection.mutable.ArrayBuffer
22+
2023
import org.apache.commons.logging.LogFactory
2124
import org.apache.hadoop.hive.conf.HiveConf
2225
import org.apache.hadoop.hive.conf.HiveConf.ConfVars
@@ -32,8 +35,6 @@ import org.apache.spark.sql.hive.thriftserver.ui.ThriftServerTab
3235
import org.apache.spark.util.Utils
3336
import org.apache.spark.{Logging, SparkContext}
3437

35-
import scala.collection.mutable
36-
import scala.collection.mutable.ArrayBuffer
3738

3839
/**
3940
* The main entry point for the Spark SQL port of HiveServer2. Starts up a `SparkSQLContext` and a

sql/hive-thriftserver/src/main/scala/org/apache/spark/sql/hive/thriftserver/SparkSQLSessionManager.scala

Lines changed: 8 additions & 6 deletions
Original file line numberDiff line numberDiff line change
@@ -30,6 +30,7 @@ import org.apache.spark.sql.hive.HiveContext
3030
import org.apache.spark.sql.hive.thriftserver.ReflectionUtils._
3131
import org.apache.spark.sql.hive.thriftserver.server.SparkSQLOperationManager
3232

33+
3334
private[hive] class SparkSQLSessionManager(hiveContext: HiveContext)
3435
extends SessionManager
3536
with ReflectedCompositeService {
@@ -50,12 +51,13 @@ private[hive] class SparkSQLSessionManager(hiveContext: HiveContext)
5051
initCompositeService(hiveConf)
5152
}
5253

53-
override def openSession(protocol: TProtocolVersion,
54-
username: String,
55-
passwd: String,
56-
sessionConf: java.util.Map[String, String],
57-
withImpersonation: Boolean,
58-
delegationToken: String): SessionHandle = {
54+
override def openSession(
55+
protocol: TProtocolVersion,
56+
username: String,
57+
passwd: String,
58+
sessionConf: java.util.Map[String, String],
59+
withImpersonation: Boolean,
60+
delegationToken: String): SessionHandle = {
5961
hiveContext.openSession()
6062
val sessionHandle = super.openSession(
6163
protocol, username, passwd, sessionConf, withImpersonation, delegationToken)

0 commit comments

Comments
 (0)