介绍
Flink SQL 除了自带的 函数,我们还可以自定义函数,扩展功能
分类
UDF按功能大致分为4类(也可以3类,聚合函数和表值聚合函数算一类):
- ScalarFunction:标量函数,把0到多个标量值映射成 1 个标量值
- TableFunction:表值函数,把0到多个标量值映射成多行数据
- AggregateFunction:聚合函数,把一行或多行数据聚合为1个值
- TableAggregateFunction:表值聚合函数 把一行或多行数据聚合为多行
参考:
https://blog.csdn.net/qq_22973811/article/details/124032836
https://blog.csdn.net/qq_21383435/article/details/106698462