, 2020 at 3:07 PM Arvid Heise wrote:
> Hi Steven,
>
> could you please provide more information. Which Flink version are you
> using? Why isn't RichAggregationFunction working for you?
>
> In general, you always have the option to use a custom window assigner and
> del
Hi Steven,
could you please provide more information. Which Flink version are you
using? Why isn't RichAggregationFunction working for you?
In general, you always have the option to use a custom window assigner and
delegate most of the calls to some provided implementation. Then you modif
I am trying to add some custom metrics to my window (because the window is
causing a lot of backpressure). However I can't seem to use a
RichAggregationFunction instead of an AggregationFunction. I am trying to
see how long things get held in our EventTimeSessionWindows.withGap window.
Is
