95-910-144-源码-FlinkSQL-Flink的UDF
Posted 九师兄
tags:
篇首语：本文由小常识网(cha138.com)小编为大家整理，主要介绍了95-910-144-源码-FlinkSQL-Flink的UDF相关的知识，希望对你有一定的参考价值。
1.世界
2.概述
用户自定义函数是非常重要的一个特征，因为他极大地扩展了查询的表达能力。
在大多数场景下，用户自定义函数在使用之前是必须要注册的。对于Scala的Table API，udf是不需要注册的。
调用TableEnvironment的registerFunction()方法来实现注册。Udf注册成功之后，会被插入TableEnvironment的function catalog，这样table API和sql就能解析他了。
本文会主要讲三种udf：
ScalarFunction
TableFunction
AggregateFunction
3.Scalar Functions 标量函数
标量函数：是指指返回一个值的函数。标量函数是实现讲0，1，或者多个标量值转化为一个新值。
实现一个标量函数需要继承
以上是关于95-910-144-源码-FlinkSQL-Flink的UDF的主要内容，如果未能解决你的问题，请参考以下文章