大数据Flink（一百零三）：SQL表值聚合函数（TableAggregateFunction）
- 人工智能
- 2025-08-15 12:21:04
文章目录
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 mon import Row from pyflink.table import DataTypes from pyflink.table.udf impo大数据Flink（一百零三）：SQL表值聚合函数（TableAggregateFunction）由讯客互联人工智能栏目发布，感谢您对讯客互联的认可，以及对我们原创作品以及文章的青睐，非常欢迎各位朋友分享到个人网站或者朋友圈，但转载请说明文章出处“大数据Flink（一百零三）：SQL表值聚合函数（TableAggregateFunction）”
