- 链接地址:https://blog.csdn.net/Direction_Wind/article/details/123873934
- 链接标题:flinksql 流表转换, 自定义udf/udtf,SQL 内置函数及自定义函数_flink sql udtf开发-CSDN博客
- 所属网站:blog.csdn.net
- 被收藏次数:1748
文章浏览阅读2.3k次。flink 自定义udf,udtf1、标量函数2、表函数3、聚合函数4、表聚合函数1、在大多数情况下,用户定义的函数必须先注册,然后才能在查询中使用。不需要专门为 Scala 的 Table API 注册函数。2、函数通过调用 registerFunction()方法在 TableEnvironment 中注册。当用户定义的函数 被注册时,它被插入到 TableEnvironment 的函数目录中,这样 Table API 或 SQL 解析器就可 以识别并正确地解释它1、标量函数用户定义的标量函数_flink sql udtf开发
版权声明:本文发布于特牛生活网 内容均来源于互联网 如有侵权联系删除