该接口的注释上有很明白的代码例子在里面，本文只是简单的记录一下并且加上个人对这个接口的理解与不解，该签名如下 AggregateFunction<IN, ACC, OUT> 泛型IN指的是输入 泛型OUT指的是输出 泛型ACC叫累加器，指的是在一个窗口周期内一直存活的一个对象，该对象是让我们对每一个过来的数据进行累加并且保存其结果的 // 每次开始统计一个窗口内的数据的时候，就会调用一次该

org.apache.flink.table.api.ValidationException: SQL validation failed. An error occurred in the type inference logic of function ‘default_catalog.default_database.CollectSetSort’. org.apache.flink.tab

一、什么是增量聚合函数 在Flink Window中定义了窗口分配器，我们只是知道了数据属于哪个窗口，可以将数据收集起来了；至于收集起来到底要做什么，其实还完全没有头绪，这也就是窗口函数所需要做的事情。所以在窗口分配器之后，我们还要再接上一个定义窗口如何进行计算的操作，这就是所谓的“窗口函数”（window functions）。 窗口可以将数据收集起来，最基本的处理操作当然就是基于窗口内的数据

一、什么是增量聚合函数 在Flink Window中定义了窗口分配器，我们只是知道了数据属于哪个窗口，可以将数据收集起来了；至于收集起来到底要做什么，其实还完全没有头绪，这也就是窗口函数所需要做的事情。所以在窗口分配器之后，我们还要再接上一个定义窗口如何进行计算的操作，这就是所谓的“窗口函数”（window functions）。 窗口可以将数据收集起来，最基本的处理操作当然就是基于窗口内的数据