Hi Steven,
AggregationFunctions (along with Reduce and other “pre aggregation”
functions) are not allowed to be Rich.
In general if you need to go outside the predefined bounds of what the
window operator provides I’d encourage you to take a look at a
KeyedProcessFunction.
Seth
On Wed, Jun 24,
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 modify
the be
