本文为您介绍Flink自定义函数UDX的分类及定义。
UDX分类
Flink支持以下3类自定义函数。
| UDX分类 | 描述 |
|---|---|
| UDF（User Defined Scalar Function） | 用户自定义标量值函数，将0个、1个或多个标量值映射到一个新的标量值。其输入与输出是一对一的关系，即读入一行数据，写出一条输出值。详情请参见自定义标量函数（UDF）。 |
| UDAF（User Defined Aggregation Function） | 自定义聚合函数，将多条记录聚合成1条记录。其输入与输出是多对一的关系，即将多条输入记录聚合成一条输出值。详情请参见自定义聚合函数（UDAF）。 |
| UDTF（User Defined Table-valued Function） | 自定义表值函数，将0个、1个或多个标量值作为输入参数（可以是变长参数）。与自定义的标量函数类似，但与标量函数不同。表值函数可以返回任意数量的行作为输出，而不仅是1个值。返回的行可以由1个或多个列组成。调用一次函数输出多行或多列数据。详情请参见自定义表值函数（UDTF）。 |
