This <https://ci.apache.org/projects/flink/flink-docs-stable/dev/stream/operators/windows.html#incremental-window-aggregation-with-aggregatefunction> 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.ma...@gmail.com> wrote: > Hi, > > > I am replacing replacing my legacy > <https://ci.apache.org/projects/flink/flink-docs-stable/dev/stream/operators/windows.html#windowfunction-legacy> > WindowFunction with AggregateFunction. > > I use TumblingEventTimeWindows, how can I get the start > <https://ci.apache.org/projects/flink/flink-docs-master/api/java/org/apache/flink/streaming/api/windowing/windows/TimeWindow.html#getStart--> > and end time? >