可以看到如果flink提供的系统内置函数不够用的话,这里就需要我们去自定义一些函数了,
在java中无非是去实现某个接口去实现自己的功能,但是要想我们写的函数,能在
flink sql或者table api中使用,那么需要在tableEnvironment中注册一下.
首先我们来看这个标量函数,这里:scalar functions就是标量函数对吧.
什么是标量函数呢,简单来说,就是,一行数据,输入进来以后,一行数据有多个字段
这一行数据,会流入到咱们的函数中,然后经过函数处理以后,得到一个结果再输出.
可以看到继承ScalarFunction去写就可以了.
注意这里要求一定要写一个eval函数而且,必须是public的才行
