Hi, 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. Thanks, Chirag
- Custom Metrics in Windowed AggregateFunction Chirag Dewan
- Re: Custom Metrics in Windowed AggregateFunction Dawid Wysakowicz
- Re: Custom Metrics in Windowed AggregateFunction Chirag Dewan