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 <[email protected]> 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?
>
