Flink Table API & SQL 自定义 Aggregate 聚合函数

Posted 2022-05-31 @SmartSi

Flink 版本：1.13.5

1. 什么是聚合函数

Aggregate function 也被称为聚合函数，主要功能是将一行或多行数据进行聚合然后输出一个标量值，例如在数据集中根据 Key 求取指定 Value 的最大值或最小值。这是一个’多对一’的转换。Flink 常见的内置聚合函数函数有 SUM()、MAX()、MIN()、AVG()、COUNT() 等。

2. 如何自定义聚合函数

自定义聚合函数 Aggregate Function 需要继承 org.apache.flink.table.functions.AggregateFunction 抽象类。AggregateFunction 有两个泛型参数 <T, ACC>，T 表示聚合输出的结果类型，ACC 则表示聚合的中间状态类型：

public class AvgAggregateFunction extends AggregateFunction<Double, AvgAggregateFu