UDX分类
| UDX分类 | 描述 |
|---|---|
| UDF(User Defined Function) | 用户自定义标量函数(User Defined Scalar Function)。其输入与输出是一对一的关系,即读入一行数据,写出一条输出值。 |
| UDAF(User Defined Aggregation Function) | 自定义聚合函数,其输入与输出是多对一的关系, 即将多条输入记录聚合成一条输出值。可以与SQL中的GROUP BY语句一起使用。 |
| UDTF(User Defined Table-valued Function) | 自定义表函数,调用一次函数输出多行或多列数据。 |
注册用户定义的函数
在大多数情况下,必须先注册用户定义的函数,然后才能在查询中使用它。没有必要为Scala Table API注册函数。
TableEnvironment通过调用registerFunction()方法来注册函数。注册用户定义的函数时,会将其插入到函数目录中TableEnvironment,以便 Table API或SQL解析器可以识别并正确转换它。
请找到如何注册,如何调用每个类型的用户定义函数(详细的例子ScalarFunction,TableFunction和AggregateFunction下面的子会话)。