Java&Scala UDF

作业创建

1. 选择java作业，并输入对应参数

sub
截取函数
com.test.SubFunction

此时从模板构建了代码，剩下函数逻辑填补即可。

这里为了方便测试，返回一段字符串

2. 接下来创建一个 FlinkSql 作业

创建函数时，复制类名，以下为测试代码

create temporary function sb_j as 'com.test.SubFunction';


CREATE TABLE sourceTable (
    id int,
    java_c string
) WITH (
  'connector' = 'datagen'
);

CREATE  TABLE sinkTable
WITH (
    'connector' = 'print'
)
LIKE sourceTable (EXCLUDING ALL);


insert into sinkTable select id,sb_j(java_c) from sourceTable;

选择执行模式，我这里采用 pre-job 进行演示

3. 执行，结果查看

查看 Taskmanager 输出，正常输出，验证成功

动图演示