how to register TableAggregateFunction?

[大森林 <ap...@foxmail.com>]

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

Re: how to register TableAggregateFunction?

[Xingbo Huang <hx...@gmail.com>]

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 <xb...@gmail.com> 于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
> <https://ci.apache.org/projects/flink/flink-docs-stable/dev/table/tableApi.html>
>
> part *Flat Aggregate*
>
>
> My code is:
>
> https://paste.ubuntu.com/p/HmB4q2WJSb/
>
> Could you tell me how to register TableAggregateFunction
>
> Thanks for your help
>
>
>

Re: how to register TableAggregateFunction?

[Leonard Xu <xb...@gmail.com>]

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 <https://ci.apache.org/projects/flink/flink-docs-stable/dev/table/tableApi.html>
> 
> part Flat Aggregate
> 
> 
> My code is:
> 
> https://paste.ubuntu.com/p/HmB4q2WJSb/
> 
> Could you tell me how to register TableAggregateFunction
> 
> Thanks for your help