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

本文主要是介绍大数据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

这篇关于大数据Flink（一百零三）：SQL 表值聚合函数（Table Aggregate Function）的文章就介绍到这儿，希望我们推荐的文章对编程师们有所帮助！

---