flink1.12.x Table API 和 SQL:UDF用户自定义函数介绍

介绍

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


原文出处:/show_1IX4Nq0n4hwO.html