Custom Metrics in Windowed AggregateFunction
I am writing a Flink job for aggregating events in a window.
I am trying to use the AggregateFunction implementation for this.
Now, since WindowedStream does not allow a RichAggregateFunction for aggregation, I cant use the RuntimeContext to get the Metric group.
I dont even see any other way of accessing the Metric Group in a non-rich function implementation?
Is there any way around here?
Any help appreciated.