Move API into connector and fix import.

apache · Nov 18, 2020 · 2eec8e5 · 2eec8e5
1 parent b3ba28d
commit 2eec8e5
Show file tree

Hide file tree

Showing 9 changed files with 9 additions and 9 deletions.
diff --git a/...ark/sql/catalog/v2/AggregateFunction.java → .../connector/catalog/AggregateFunction.java b/...ark/sql/catalog/v2/AggregateFunction.java → .../connector/catalog/AggregateFunction.java
@@ -15,7 +15,7 @@
  * limitations under the License.
  */
 
-package org.apache.spark.sql.catalog.v2;
+package org.apache.spark.sql.connector.catalog;
 
 import org.apache.spark.sql.catalyst.InternalRow;
 import org.apache.spark.sql.types.DataType;

diff --git a/...alog/v2/AssociativeAggregateFunction.java → ...catalog/AssociativeAggregateFunction.java b/...alog/v2/AssociativeAggregateFunction.java → ...catalog/AssociativeAggregateFunction.java
@@ -15,7 +15,7 @@
  * limitations under the License.
  */
 
-package org.apache.spark.sql.catalog.v2;
+package org.apache.spark.sql.connector.catalog;
 
 import java.io.Serializable;
 

diff --git a/...e/spark/sql/catalog/v2/BoundFunction.java → .../sql/connector/catalog/BoundFunction.java b/...e/spark/sql/catalog/v2/BoundFunction.java → .../sql/connector/catalog/BoundFunction.java
@@ -15,7 +15,7 @@
  * limitations under the License.
  */
 
-package org.apache.spark.sql.catalog.v2;
+package org.apache.spark.sql.connector.catalog;
 
 import org.apache.spark.sql.types.DataType;
 import org.apache.spark.sql.types.IntegerType;

diff --git a/...apache/spark/sql/catalog/v2/Function.java → ...spark/sql/connector/catalog/Function.java b/...apache/spark/sql/catalog/v2/Function.java → ...spark/sql/connector/catalog/Function.java
@@ -15,7 +15,7 @@
  * limitations under the License.
  */
 
-package org.apache.spark.sql.catalog.v2;
+package org.apache.spark.sql.connector.catalog;
 
 import java.io.Serializable;
 

diff --git a/...spark/sql/catalog/v2/FunctionCatalog.java → ...ql/connector/catalog/FunctionCatalog.java b/...spark/sql/catalog/v2/FunctionCatalog.java → ...ql/connector/catalog/FunctionCatalog.java
@@ -15,7 +15,7 @@
  * limitations under the License.
  */
 
-package org.apache.spark.sql.catalog.v2;
+package org.apache.spark.sql.connector.catalog;
 
 import org.apache.spark.sql.catalyst.analysis.NoSuchFunctionException;
 import org.apache.spark.sql.catalyst.analysis.NoSuchNamespaceException;

diff --git a/.../spark/sql/catalog/v2/ScalarFunction.java → ...sql/connector/catalog/ScalarFunction.java b/.../spark/sql/catalog/v2/ScalarFunction.java → ...sql/connector/catalog/ScalarFunction.java
@@ -15,7 +15,7 @@
  * limitations under the License.
  */
 
-package org.apache.spark.sql.catalog.v2;
+package org.apache.spark.sql.connector.catalog;
 
 import org.apache.spark.sql.catalyst.InternalRow;
 import org.apache.spark.sql.types.DataType;

diff --git a/...spark/sql/catalog/v2/UnboundFunction.java → ...ql/connector/catalog/UnboundFunction.java b/...spark/sql/catalog/v2/UnboundFunction.java → ...ql/connector/catalog/UnboundFunction.java
@@ -15,7 +15,7 @@
  * limitations under the License.
  */
 
-package org.apache.spark.sql.catalog.v2;
+package org.apache.spark.sql.connector.catalog;
 
 import org.apache.spark.sql.types.StructType;
 

diff --git a/sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/analysis/NoSuchItemException.scala b/sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/analysis/NoSuchItemException.scala
@@ -69,7 +69,7 @@ class NoSuchFunctionException(
     msg: String,
     cause: Option[Throwable]) extends AnalysisException(msg, cause = cause) {
 
-  import org.apache.spark.sql.catalog.v2.CatalogV2Implicits._
+  import org.apache.spark.sql.connector.catalog.CatalogV2Implicits._
 
   def this(db: String, func: String, cause: Option[Throwable] = None) = {
     this(s"Undefined function: '$func'. " +

diff --git a/...l/catalog/v2/AggregateFunctionSuite.scala → ...ctor/catalog/AggregateFunctionSuite.scala b/...l/catalog/v2/AggregateFunctionSuite.scala → ...ctor/catalog/AggregateFunctionSuite.scala
@@ -15,7 +15,7 @@
  * limitations under the License.
  */
 
-package org.apache.spark.sql.catalog.v2
+package org.apache.spark.sql.connector.catalog
 
 import org.apache.spark.SparkFunSuite
 import org.apache.spark.sql.catalyst.InternalRow