Hi,
Thanks for your response, I guess what I need should be this one (UDTAGG):
https://nightlies.apache.org/flink/flink-docs-master/docs/dev/table/functions/udfs/#table-aggregate-functions
As I want multiple rows as aggregate output. So my question: can we use UDTAGG
in flink SQL?. If so, is there some guide of how to use UDTAGG in flink SQL?
As there are only flink table api instructions of UDTAGG in the page above.
Thanks,
Hunk
At 2022-08-08 10:56:22, "Xuyang" <xyzhong...@163.com> wrote:
>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
