replacing WindowFunction with AggregateFunction

[Nicos Maris]

Hi,

I am replacing replacing my legacy WindowFunction with AggregateFunction.

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

[Nicos Maris]

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 <[hidden email]> wrote:

Hi,

I am replacing replacing my legacy WindowFunction with AggregateFunction.

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

[Hequn Cheng]

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 <[hidden email]> wrote:

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 <[hidden email]> wrote:

Hi,

I am replacing replacing my legacy WindowFunction with AggregateFunction.

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