MapReduce服务 MRS-配置管理UDF:UDF java代码及SQL样例

时间：2023-11-01 16:25:25

MapReduce服务 MRS

UDF java代码及SQL样例

UDF java使用样例

package com.xxx.udf;import org.apache.flink.table.functions.ScalarFunction;public class UdfClass_UDF extends ScalarFunction {    public int eval(String s) {        return s.length();    }}

UDF SQL使用样例

CREATE TEMPORARY FUNCTION udf as 'com.xxx.udf.UdfClass_UDF';CREATE TABLE udfSource (a VARCHAR) WITH ('connector' = 'datagen','rows-per-second'='1');CREATE TABLE udfSink (a VARCHAR,b int) WITH ('connector' = 'print');INSERT INTO  udfSinkSELECT  a,  udf(a)FROM  udfSource;

上一篇：MapReduce服务 MRS-配置管理UDF:上传UDF

下一篇：MapReduce服务 MRS-ALTER TABLE修改表结构:使用示例