Re: [DISCUSS] FLINK-21109: Introduce "retractAccumulators" interface for AggregateFunction in Table/SQL API

2021-01-28 Thread DONG, Weike
Hi Jark, +1 for this proposal. Glad to see more details : ) Sincerely, Weike On Mon, Jan 25, 2021 at 2:03 PM Jark Wu wrote: > Hi all, > > I would like to propose introducing a new method "retractAccumulators()" to > the `AggregateFunction` in Table/SQL. > > *Motivation* > > The motivation is

[DISCUSS] FLINK-21109: Introduce "retractAccumulators" interface for AggregateFunction in Table/SQL API

2021-01-24 Thread Jark Wu
Hi all, I would like to propose introducing a new method "retractAccumulators()" to the `AggregateFunction` in Table/SQL. *Motivation* The motivation is to improve the performance of hopping (sliding) windows. Currently, we have paned (or called sliced) optimization for the hopping windows in