Hi, wang Maybe you can take a look at https://nightlies.apache.org/flink/flink-docs-master/docs/dev/table/sql/create/#create-function
Best, Weihua On Mon, Aug 8, 2022 at 3:52 PM wang <24248...@163.com> wrote: > > > > 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 >
