codehaus


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

Re: Need the way to create custom metrics


Hi,

AFAIK it is not possible to collect metrics for an AggregateFunction.
You can open a feature request by creating a Jira issue.

Thanks,
Fabian


Am Mo., 17. Dez. 2018 um 21:29 Uhr schrieb Gaurav Luthra <gauravluthra6134@xxxxxxxxx>:
Hi,

I need to know the way to implement custom metrics in my flink program.
Currently, I know we can create custom metrics with the help of RuntimeContext. 
But in my aggregate() I do not have RuntimeContext. I am using window operator and applying aggregate() method on it. And I am passing AggregateFunction in aggregate() method.

So, Kindly guide me, how can I create custom metrics in my code?

Note: As we know we can not user RichAggregateFunction with aggregate() method 

Thanks & Regards
Gaurav Luthra
Mob:- +91-9901945206