This is an automated email from the ASF dual-hosted git repository.

jiayu pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/sedona.git


The following commit(s) were added to refs/heads/master by this push:
     new edafd75953 [SEDONA-710] fix bug in AbstractCatalog referencing 
Catalog. (#1810)
edafd75953 is described below

commit edafd75953b595c906a8124b3a00878a33ddad6e
Author: James Willis <[email protected]>
AuthorDate: Wed Feb 12 20:33:22 2025 -0800

    [SEDONA-710] fix bug in AbstractCatalog referencing Catalog. (#1810)
    
    Co-authored-by: jameswillis <[email protected]>
---
 .../main/scala/org/apache/sedona/sql/UDF/AbstractCatalog.scala    | 8 ++++----
 1 file changed, 4 insertions(+), 4 deletions(-)

diff --git 
a/spark/common/src/main/scala/org/apache/sedona/sql/UDF/AbstractCatalog.scala 
b/spark/common/src/main/scala/org/apache/sedona/sql/UDF/AbstractCatalog.scala
index f8bb0ac5fe..6da8f56c32 100644
--- 
a/spark/common/src/main/scala/org/apache/sedona/sql/UDF/AbstractCatalog.scala
+++ 
b/spark/common/src/main/scala/org/apache/sedona/sql/UDF/AbstractCatalog.scala
@@ -81,21 +81,21 @@ abstract class AbstractCatalog {
   }
 
   def registerAll(sparkSession: SparkSession): Unit = {
-    Catalog.expressions.foreach { case (functionIdentifier, expressionInfo, 
functionBuilder) =>
+    expressions.foreach { case (functionIdentifier, expressionInfo, 
functionBuilder) =>
       sparkSession.sessionState.functionRegistry.registerFunction(
         functionIdentifier,
         expressionInfo,
         functionBuilder)
     }
-    Catalog.aggregateExpressions.foreach(f =>
+    aggregateExpressions.foreach(f =>
       sparkSession.udf.register(f.getClass.getSimpleName, functions.udaf(f)))
   }
 
   def dropAll(sparkSession: SparkSession): Unit = {
-    Catalog.expressions.foreach { case (functionIdentifier, _, _) =>
+    expressions.foreach { case (functionIdentifier, _, _) =>
       
sparkSession.sessionState.functionRegistry.dropFunction(functionIdentifier)
     }
-    Catalog.aggregateExpressions.foreach(f =>
+    aggregateExpressions.foreach(f =>
       sparkSession.sessionState.functionRegistry.dropFunction(
         FunctionIdentifier(f.getClass.getSimpleName)))
   }

Reply via email to