[Fix][core] new Func Adapt to 1.3.2feature/1.3.2

2 files changed, 3 insertions, 3 deletions

diff --git a/groot-core/src/main/java/com/geedgenetworks/core/udf/cn/BaseStationLookup.java b/groot-core/src/main/java/com/geedgenetworks/core/udf/cn/BaseStationLookup.java
index d506461..92521db 100644
--- a/groot-core/src/main/java/com/geedgenetworks/core/udf/cn/BaseStationLookup.java
+++ b/groot-core/src/main/java/com/geedgenetworks/core/udf/cn/BaseStationLookup.java
@@ -16,7 +16,7 @@ import java.util.Map;
  * @version 1.0
  * @date 2024/8/19 15:21
  */
-public class BaseStationLookup extends AbstractKnowledgeScalarFunction {
+public class BaseStationLookup extends AbstractKnowledgeUDF {
 
     private String cellIdFieldName;
 
diff --git a/groot-core/src/main/java/com/geedgenetworks/core/udf/cn/H3CellLookup.java b/groot-core/src/main/java/com/geedgenetworks/core/udf/cn/H3CellLookup.java
index 2698772..dee913f 100644
--- a/groot-core/src/main/java/com/geedgenetworks/core/udf/cn/H3CellLookup.java
+++ b/groot-core/src/main/java/com/geedgenetworks/core/udf/cn/H3CellLookup.java
@@ -3,7 +3,7 @@ package com.geedgenetworks.core.udf.cn;
 import com.geedgenetworks.common.Event;
 import com.geedgenetworks.common.exception.CommonErrorCode;
 import com.geedgenetworks.common.exception.GrootStreamRuntimeException;
-import com.geedgenetworks.common.udf.ScalarFunction;
+import com.geedgenetworks.common.udf.UDF;
 import com.geedgenetworks.common.udf.UDFContext;
 import com.uber.h3core.H3Core;
 import org.apache.flink.api.common.functions.RuntimeContext;
@@ -17,7 +17,7 @@ import java.util.Map;
  * @version 1.0
  * @date 2024/8/19 14:50
  */
-public class H3CellLookup implements ScalarFunction {
+public class H3CellLookup implements UDF {
 
     private String longitudeFieldName;