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)))
}