flink sql热加载自定义函数 不重启flink集群

1. 流程

第一步 先写好udf 函数

  // 自定义函数类
    public static class  myFunction extends ScalarFunction{
        public int eval(String value) {
            return value.length();
        }
    }
1
2
3
4
5
6

第二步打包后 放到一个位置比如：flink/lib 中

第三步： 进入flink 客户端 ./sql-client.sh embeded
第四步： 进行进入当前的catalog 中
第五步： 在客户端中执行

 add  jar  '/flink/lib/demo.jar'
 show jars
create function 函数名称  as   'com.bigdata.myfunction(类的全路径)'

就可以用了
1
2
3
4
5