文章目录
SQL 表值聚合函数(Table Aggregate Function)
SQL 表值聚合函数(Table Aggregate Function)
Python UDTAF,即 Python TableAggregateFunction。Python UDTAF 用来针对一组数据进行聚合运算,比如同一个 window 下的多条数据、或者同一个 key 下的多条数据等,与 Python UDAF 不同的是,针对同一组输入数据,Python UDTAF 可以产生 0 条、1 条、甚至多条输出数据。文章来源:https://www.toymoban.com/news/detail-725937.html
以下示例,定义了一个名字为 Top2 的 Python UDTAF:文章来源地址https://www.toymoban.com/news/detail-725937.html
from pyflink.common import Row
from pyflink.table import DataTypes
from pyflink
到了这里,关于大数据Flink(一百零三):SQL 表值聚合函数(Table Aggregate Function)的文章就介绍完了。如果您还想了解更多内容,请在右上角搜索TOY模板网以前的文章或继续浏览下面的相关文章,希望大家以后多多支持TOY模板网!