特牛生活网

flinksql 流表转换, 自定义udf/udtf,SQL 内置函数及自定义函数_flink sql udtf开发-CSDN博客

网友收藏
文章浏览阅读2.3k次。flink 自定义udf,udtf1、标量函数2、表函数3、聚合函数4、表聚合函数1、在大多数情况下,用户定义的函数必须先注册,然后才能在查询中使用。不需要专门为 Scala 的 Table API 注册函数。2、函数通过调用 registerFunction()方法在 TableEnvironment 中注册。当用户定义的函数 被注册时,它被插入到 TableEnvironment 的函数目录中,这样 Table API 或 SQL 解析器就可 以识别并正确地解释它1、标量函数用户定义的标量函数_flink sql udtf开发