大数据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
```
相关阅读:
在Oracle 11g 数据库上设置透明数据加密（TDE）
android ＜String＞添加空格等特殊字符
 推荐算法学习笔记2.1:基于深度学习的推荐算法-基于共线矩阵的深度推荐算法-AutoRec模型
 SharpShooter Reports.Web 7.5 Crack
UseGalaxy.cn生信云|生物信息必备技能-出版级别的circos圈图绘制
 【数据库MySql】数据库基础——库和表的基础操作
 PostgreSQL 长事务导致表膨胀的原因
 ERAT读和写指令（eratre和eratwe）
智慧物流仓储仓库温湿度管理采集器钡铼技术远程终端RTU的使用
 Vue学习笔记-全局事件总线
原文地址：https://blog.csdn.net/xiaoweite1/article/details/134068367