Re: get state from window

[yuxia]

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

Best regards,
Yuxia

- 原始邮件 -
发件人: "yuxia" 
收件人: "user-zh" 
抄送: "User" 
发送时间: 星期四, 2022年 8 月 18日 上午 10:21:12
主题: Re: get state from window

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

Best regards,
Yuxia

- 原始邮件 -
发件人: "曲洋" 
收件人: "user-zh" , "User" 
发送时间: 星期四, 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!

Re: get state from window

[yanfei lei]

Hi,  there are two methods on the Context object that a process() invocation
receives that allows access to the two types of state:

   - globalState(), which allows access to keyed state that is not scoped
   to a window
   - windowState(), which allows access to keyed state that is also scoped
   to the window

maybe you can refer to the implementation of WindowReaderTest

.

Best,
Yanfei

2022年8月18日 上午10:05，曲洋  写道：

Hi dear engineers,

I have one question:  does flink streaming support getting the state.I
override the open method in the map processor,initializing the state(some
metric for the data) .How can I get the state in my window?

Thanks for your help!

Re: get state from window

[yuxia]

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

Best regards,
Yuxia

- 原始邮件 -
发件人: "曲洋" 
收件人: "user-zh" , "User" 
发送时间: 星期四, 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!

退订

[信华哺]

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 the state(some metric for the 
data) .How can I get the state in my window?

Thanks for your help!

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!

flink sink kafka exactly once????

[kcz]

flink-1.14.4kafka-2.4.0setTransactionalIdPrefixjob??IDchkIDSystem.currentTimeMillis()ID??KafkaSink