git.net

[Date Prev][Date Next][Thread Prev][Thread Next][Date Index][Thread Index]

Re: replacing WindowFunction with AggregateFunction


This seams to be the way to go but I get "cannot resolve method" at the method 'aggregate'.

My aggregareFunction implements the following:

AggregateFunction<
IngressPOJO,
CountersAccumulator,
CountersAccumulator
>
And my processWindowFunction implements the following:

ProcessWindowFunction<
CountersAccumulator,
Tuple2<String, CountersAccumulator>,
String,
TimeWindow
>

On Sun, Sep 9, 2018 at 4:40 AM Nicos Maris <nicos.maris@xxxxxxxxx> wrote:
Hi,


I am replacing replacing my legacy WindowFunction with AggregateFunction.

I use TumblingEventTimeWindows, how can I get the start and end time?