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
下面的子会话)。