flinkSQL用户自定义函数(UDX)


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 APISQL解析器可以识别并正确转换它。

请找到如何注册,如何调用每个类型的用户定义函数(详细的例子ScalarFunctionTableFunctionAggregateFunction下面的子会话)。

自定义标量函数UDF

自定义聚合函数UDAF

自定义表值函数UDTF


文章作者: wuzhiyong
版权声明: 本博客所有文章除特別声明外,均采用 CC BY 4.0 许可协议。转载请注明来源 wuzhiyong !
评论
 上一篇
互联网上的时间-RFC3339 互联网上的时间-RFC3339
RFC3339本地时间只包括当前的时间,不包含任何时区信息。同一时刻,东八区的本地时间比零时区的本地时间快了8个小时。在不同时区之间交换时间数据,除了用纯数字的时间戳,还有一种更方便人类阅读的表示方式:标准时间的偏移量表示方法。 RFC33
2020-03-26
下一篇 
flinkSQL时间戳转换成日期格式 flinkSQL时间戳转换成日期格式
问题{"id":5,"price":40,"ts":1585125854697,"type":"math"} {"id":3,"price":60,"ts":1585125861687,"type":"ph"} {"id":1,"price
2020-03-25
  目录