Hi, what you want is UDAF? Please check whether this[1] is meet your requirement.
[1] https://nightlies.apache.org/flink/flink-docs-master/docs/dev/table/functions/udfs/#aggregate-functions 在 2022-08-07 22:06:29，"wang" <24248...@163.com> 写道： Hi dear engineers, One small question: does flink sql support UDTAGG? (user-defined table aggregate function), seems only supported in flink table api? If not supported in flink sql, how can I define an aggregated udf which could output multiple rows to kafka. Thanks for your help! Regards, Hunk
