diff options
| -rw-r--r-- | groot-core/src/main/java/com/geedgenetworks/core/udf/cn/BaseStationLookup.java | 2 | ||||
| -rw-r--r-- | groot-core/src/main/java/com/geedgenetworks/core/udf/cn/H3CellLookup.java | 4 |
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; |