Sorry for misleading.
After some investigation, seems UDTAGG can only used in flink table spi.

Best regards,
Yuxia

----- 原始邮件 -----
发件人: "yuxia" <luoyu...@alumni.sjtu.edu.cn>
收件人: "user-zh" <user...@flink.apache.org>
抄送: "User" <user@flink.apache.org>
发送时间: 星期四, 2022年 8 月 18日 上午 10:21:12
主题: Re: get state from window

> does flink sql support UDTAGG?
Yes, Flink sql support UDTAGG.

Best regards,
Yuxia

----- 原始邮件 -----
发件人: "曲洋" <quyanghao...@126.com>
收件人: "user-zh" <user...@flink.apache.org>, "User" <user@flink.apache.org>
发送时间: 星期四, 2022年 8 月 18日 上午 10:03:24
主题: get state from window

Hi dear engineers,

I have one question:  does flink streaming support getting the state.I override 
the open method in the map processor,initializing
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!
Thanks for your help!

Reply via email to