Hi Nicos, I think it should be a type problem. Make sure the input DataStream is type of `IngressPOJO `. There are examples here[1][2] which may be helpful.
Best, Hequn [1] https://github.com/apache/flink/blob/master/flink-streaming-java/src/test/java/org/apache/flink/streaming/runtime/operators/windowing/WindowTranslationTest.java [2] https://github.com/apache/flink/blob/master/flink-tests/src/test/java/org/apache/flink/test/checkpointing/EventTimeWindowCheckpointingITCase.java On Sun, Sep 9, 2018 at 10:03 AM Nicos Maris <nicos.ma...@gmail.com> wrote: > 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? >> >
