save

turboFei · Nov 18, 2023 · c3f8fca · c3f8fca
1 parent 8871cc3
commit c3f8fca
Show file tree

Hide file tree

Showing 11 changed files with 22 additions and 22 deletions.
diff --git a/kyuubi-server/src/main/scala/org/apache/kyuubi/operation/ExecuteStatement.scala b/kyuubi-server/src/main/scala/org/apache/kyuubi/operation/ExecuteStatement.scala
@@ -29,10 +29,10 @@ import org.apache.kyuubi.config.KyuubiConf.OPERATION_QUERY_TIMEOUT_MONITOR_ENABL
 import org.apache.kyuubi.metrics.{MetricsConstants, MetricsSystem}
 import org.apache.kyuubi.operation.FetchOrientation.FETCH_NEXT
 import org.apache.kyuubi.operation.log.OperationLog
-import org.apache.kyuubi.session.Session
+import org.apache.kyuubi.session.KyuubiSession
 
 class ExecuteStatement(
-    session: Session,
+    session: KyuubiSession,
     override val statement: String,
     confOverlay: Map[String, String],
     override val shouldRunAsync: Boolean,

diff --git a/kyuubi-server/src/main/scala/org/apache/kyuubi/operation/GetCatalogs.scala b/kyuubi-server/src/main/scala/org/apache/kyuubi/operation/GetCatalogs.scala
@@ -17,9 +17,9 @@
 
 package org.apache.kyuubi.operation
 
-import org.apache.kyuubi.session.Session
+import org.apache.kyuubi.session.KyuubiSession
 
-class GetCatalogs(session: Session) extends KyuubiOperation(session) {
+class GetCatalogs(session: KyuubiSession) extends KyuubiOperation(session) {
 
   override protected def runKyuubiOperationInternal(): Unit = {
     try {

diff --git a/kyuubi-server/src/main/scala/org/apache/kyuubi/operation/GetColumns.scala b/kyuubi-server/src/main/scala/org/apache/kyuubi/operation/GetColumns.scala
@@ -17,10 +17,10 @@
 
 package org.apache.kyuubi.operation
 
-import org.apache.kyuubi.session.Session
+import org.apache.kyuubi.session.KyuubiSession
 
 class GetColumns(
-    session: Session,
+    session: KyuubiSession,
     catalogName: String,
     schemaName: String,
     tableName: String,

diff --git a/kyuubi-server/src/main/scala/org/apache/kyuubi/operation/GetCrossReference.scala b/kyuubi-server/src/main/scala/org/apache/kyuubi/operation/GetCrossReference.scala
@@ -17,10 +17,10 @@
 
 package org.apache.kyuubi.operation
 
-import org.apache.kyuubi.session.Session
+import org.apache.kyuubi.session.KyuubiSession
 
 class GetCrossReference(
-    session: Session,
+    session: KyuubiSession,
     primaryCatalog: String,
     primarySchema: String,
     primaryTable: String,

diff --git a/kyuubi-server/src/main/scala/org/apache/kyuubi/operation/GetFunctions.scala b/kyuubi-server/src/main/scala/org/apache/kyuubi/operation/GetFunctions.scala
@@ -17,10 +17,10 @@
 
 package org.apache.kyuubi.operation
 
-import org.apache.kyuubi.session.Session
+import org.apache.kyuubi.session.KyuubiSession
 
 class GetFunctions(
-    session: Session,
+    session: KyuubiSession,
     catalogName: String,
     schemaName: String,
     functionName: String)

diff --git a/kyuubi-server/src/main/scala/org/apache/kyuubi/operation/GetPrimaryKeys.scala b/kyuubi-server/src/main/scala/org/apache/kyuubi/operation/GetPrimaryKeys.scala
@@ -17,10 +17,10 @@
 
 package org.apache.kyuubi.operation
 
-import org.apache.kyuubi.session.Session
+import org.apache.kyuubi.session.KyuubiSession
 
 class GetPrimaryKeys(
-    session: Session,
+    session: KyuubiSession,
     catalogName: String,
     schemaName: String,
     tableName: String)

diff --git a/kyuubi-server/src/main/scala/org/apache/kyuubi/operation/GetSchemas.scala b/kyuubi-server/src/main/scala/org/apache/kyuubi/operation/GetSchemas.scala
@@ -17,10 +17,10 @@
 
 package org.apache.kyuubi.operation
 
-import org.apache.kyuubi.session.Session
+import org.apache.kyuubi.session.KyuubiSession
 
 class GetSchemas(
-    session: Session,
+    session: KyuubiSession,
     catalogName: String,
     schemaName: String)
   extends KyuubiOperation(session) {

diff --git a/kyuubi-server/src/main/scala/org/apache/kyuubi/operation/GetTableTypes.scala b/kyuubi-server/src/main/scala/org/apache/kyuubi/operation/GetTableTypes.scala
@@ -17,9 +17,9 @@
 
 package org.apache.kyuubi.operation
 
-import org.apache.kyuubi.session.Session
+import org.apache.kyuubi.session.KyuubiSession
 
-class GetTableTypes(session: Session) extends KyuubiOperation(session) {
+class GetTableTypes(session: KyuubiSession) extends KyuubiOperation(session) {
 
   override protected def runKyuubiOperationInternal(): Unit = {
     try {

diff --git a/kyuubi-server/src/main/scala/org/apache/kyuubi/operation/GetTables.scala b/kyuubi-server/src/main/scala/org/apache/kyuubi/operation/GetTables.scala
@@ -17,10 +17,10 @@
 
 package org.apache.kyuubi.operation
 
-import org.apache.kyuubi.session.Session
+import org.apache.kyuubi.session.KyuubiSession
 
 class GetTables(
-    session: Session,
+    session: KyuubiSession,
     catalogName: String,
     schemaName: String,
     tableName: String,

diff --git a/kyuubi-server/src/main/scala/org/apache/kyuubi/operation/GetTypeInfo.scala b/kyuubi-server/src/main/scala/org/apache/kyuubi/operation/GetTypeInfo.scala
@@ -17,9 +17,9 @@
 
 package org.apache.kyuubi.operation
 
-import org.apache.kyuubi.session.Session
+import org.apache.kyuubi.session.KyuubiSession
 
-class GetTypeInfo(session: Session) extends KyuubiOperation(session) {
+class GetTypeInfo(session: KyuubiSession) extends KyuubiOperation(session) {
 
   override protected def runKyuubiOperationInternal(): Unit = {
     try {

diff --git a/kyuubi-server/src/main/scala/org/apache/kyuubi/operation/KyuubiApplicationOperation.scala b/kyuubi-server/src/main/scala/org/apache/kyuubi/operation/KyuubiApplicationOperation.scala
@@ -26,10 +26,10 @@ import org.apache.hive.service.rpc.thrift.{TColumn, TColumnDesc, TFetchResultsRe
 
 import org.apache.kyuubi.engine.ApplicationInfo
 import org.apache.kyuubi.operation.FetchOrientation.FetchOrientation
-import org.apache.kyuubi.session.Session
+import org.apache.kyuubi.session.KyuubiSession
 import org.apache.kyuubi.util.ThriftUtils
 
-abstract class KyuubiApplicationOperation(session: Session) extends KyuubiOperation(session) {
+abstract class KyuubiApplicationOperation(session: KyuubiSession) extends KyuubiOperation(session) {
 
   protected def currentApplicationInfo(): Option[ApplicationInfo]