Re: replacing WindowFunction with AggregateFunction

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/

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: AggregateFunc