how to register TableAggregateFunction?

classic Classic list List threaded Threaded
3 messages Options
Reply | Threaded
Open this post in threaded view
|

how to register TableAggregateFunction?

大森林

I'm learning document

part Flat Aggregate


My code is:

https://paste.ubuntu.com/p/HmB4q2WJSb/

Could you tell me how to register TableAggregateFunction

Thanks for your help
Reply | Threaded
Open this post in threaded view
|

Re: how to register TableAggregateFunction?

Leonard Xu
Hi, appleyuchi 

Sorry for the late reply, 
but could you describe you problem more  or post your exception stack? The doc you posted has contained the section to define and register function.
 
And I suggest you post your entire code in email directly that can reproduce the problem, thus the community 
can understand and help you resolve the question better.

Best,
Leonard



 
I'm learning document

part Flat Aggregate


My code is:


Could you tell me how to register TableAggregateFunction

Thanks for your help

Reply | Threaded
Open this post in threaded view
|

Re: how to register TableAggregateFunction?

Xingbo Huang
Hi,

As far as I know, TableAggregateFunction is not supported yet in batch mode[1]. You can try to use it in stream mode.


[1] https://issues.apache.org/jira/browse/FLINK-10978

Best,
Xingbo

Leonard Xu <[hidden email]> 于2020年12月8日周二 下午6:05写道:
Hi, appleyuchi 

Sorry for the late reply, 
but could you describe you problem more  or post your exception stack? The doc you posted has contained the section to define and register function.
 
And I suggest you post your entire code in email directly that can reproduce the problem, thus the community 
can understand and help you resolve the question better.

Best,
Leonard



 
I'm learning document

part Flat Aggregate


My code is:


Could you tell me how to register TableAggregateFunction

Thanks for your help