[Date Prev][Date Next][Thread Prev][Thread Next][Date Index][Thread Index]

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.