Flink CDC中我自定义的udaf函数，为什么只有+I的数据（后期修改）可以做统计？

Flink CDC 中自定义 UDAF 函数，只有 +I 的数据（后期修改）可以做统计，是因为 CDC 本身的特性决定的。

CDC 是 Change Data Capture 的缩写，它是一种用于实时捕获数据库表中的数据变化的技术。CDC 会根据数据库表的变更历史，生成一个增量数据流。这个增量数据流只包含数据库表中新增的数据和修改的数据，不包含删除的数据。

因此，Flink CDC 中自定义的 UDAF 函数，只能对新增的数据和修改的数据进行统计。对于删除的数据，UDAF 函数是不支持的。

你可以使用 Flink CDC 中提供的 Table API 和 SQL 来进行数据统计。Table API 和 SQL 可以对新增的数据和修改的数据进行统计，也可以对删除的数据进行统计。

所以，如果需要对数据库表中的数据进行统计，建议使用 Table API 和 SQL，而不是自定义 UDAF 函数。