Skip to content

Commit 1721075

Browse files
committed
Move function interfaces into a separate package to avoid conflicts.
1 parent 2eec8e5 commit 1721075

File tree

8 files changed

+8
-8
lines changed

8 files changed

+8
-8
lines changed

sql/catalyst/src/main/java/org/apache/spark/sql/connector/catalog/FunctionCatalog.java

Lines changed: 1 addition & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -19,6 +19,7 @@
1919

2020
import org.apache.spark.sql.catalyst.analysis.NoSuchFunctionException;
2121
import org.apache.spark.sql.catalyst.analysis.NoSuchNamespaceException;
22+
import org.apache.spark.sql.connector.catalog.functions.UnboundFunction;
2223

2324
/**
2425
* Catalog methods for working with Functions.

sql/catalyst/src/main/java/org/apache/spark/sql/connector/catalog/AggregateFunction.java renamed to sql/catalyst/src/main/java/org/apache/spark/sql/connector/catalog/functions/AggregateFunction.java

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -15,7 +15,7 @@
1515
* limitations under the License.
1616
*/
1717

18-
package org.apache.spark.sql.connector.catalog;
18+
package org.apache.spark.sql.connector.catalog.functions;
1919

2020
import org.apache.spark.sql.catalyst.InternalRow;
2121
import org.apache.spark.sql.types.DataType;

sql/catalyst/src/test/java/org/apache/spark/sql/connector/catalog/AggregateFunctionSuite.scala renamed to sql/catalyst/src/main/java/org/apache/spark/sql/connector/catalog/functions/AggregateFunctionSuite.scala

Lines changed: 1 addition & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -15,9 +15,8 @@
1515
* limitations under the License.
1616
*/
1717

18-
package org.apache.spark.sql.connector.catalog
18+
package org.apache.spark.sql.connector.catalog.functions
1919

20-
import org.apache.spark.SparkFunSuite
2120
import org.apache.spark.sql.catalyst.InternalRow
2221
import org.apache.spark.sql.types.{DataType, IntegerType, LongType, StructType}
2322

sql/catalyst/src/main/java/org/apache/spark/sql/connector/catalog/AssociativeAggregateFunction.java renamed to sql/catalyst/src/main/java/org/apache/spark/sql/connector/catalog/functions/AssociativeAggregateFunction.java

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -15,7 +15,7 @@
1515
* limitations under the License.
1616
*/
1717

18-
package org.apache.spark.sql.connector.catalog;
18+
package org.apache.spark.sql.connector.catalog.functions;
1919

2020
import java.io.Serializable;
2121

sql/catalyst/src/main/java/org/apache/spark/sql/connector/catalog/BoundFunction.java renamed to sql/catalyst/src/main/java/org/apache/spark/sql/connector/catalog/functions/BoundFunction.java

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -15,7 +15,7 @@
1515
* limitations under the License.
1616
*/
1717

18-
package org.apache.spark.sql.connector.catalog;
18+
package org.apache.spark.sql.connector.catalog.functions;
1919

2020
import org.apache.spark.sql.types.DataType;
2121
import org.apache.spark.sql.types.IntegerType;

sql/catalyst/src/main/java/org/apache/spark/sql/connector/catalog/Function.java renamed to sql/catalyst/src/main/java/org/apache/spark/sql/connector/catalog/functions/Function.java

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -15,7 +15,7 @@
1515
* limitations under the License.
1616
*/
1717

18-
package org.apache.spark.sql.connector.catalog;
18+
package org.apache.spark.sql.connector.catalog.functions;
1919

2020
import java.io.Serializable;
2121

sql/catalyst/src/main/java/org/apache/spark/sql/connector/catalog/ScalarFunction.java renamed to sql/catalyst/src/main/java/org/apache/spark/sql/connector/catalog/functions/ScalarFunction.java

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -15,7 +15,7 @@
1515
* limitations under the License.
1616
*/
1717

18-
package org.apache.spark.sql.connector.catalog;
18+
package org.apache.spark.sql.connector.catalog.functions;
1919

2020
import org.apache.spark.sql.catalyst.InternalRow;
2121
import org.apache.spark.sql.types.DataType;

sql/catalyst/src/main/java/org/apache/spark/sql/connector/catalog/UnboundFunction.java renamed to sql/catalyst/src/main/java/org/apache/spark/sql/connector/catalog/functions/UnboundFunction.java

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -15,7 +15,7 @@
1515
* limitations under the License.
1616
*/
1717

18-
package org.apache.spark.sql.connector.catalog;
18+
package org.apache.spark.sql.connector.catalog.functions;
1919

2020
import org.apache.spark.sql.types.StructType;
2121

0 commit comments

Comments
 (0)