大数据Flink（一百零三）：SQL 表值聚合函数（Table Aggregate Function）

文章目录

SQL 表值聚合函数（Table Aggregate Function）

SQL 表值聚合函数（Table Aggregate Function）

Python UDTAF，即 Python TableAggregateFunction。Python UDTAF 用来针对一组数据进行聚合运算，比如同一个 window 下的多条数据、或者同一个 key 下的多条数据等，与 Python UDAF 不同的是，针对同一组输入数据，Python UDTAF 可以产生 0 条、1 条、甚至多条输出数据。

以下示例，定义了一个名字为 Top2 的 Python UDTAF：

from pyflink.common import Row
from pyflink.table import DataTypes
from pyflink.table.udf impo