Re: Need the way to create custom metrics
I have a similar issue. I raised a JIRA : https://issues.apache.org/jira/browse/FLINK-11198 Thanks, Chirag On Wednesday, 19 December, 2018, 11:35:02 AM IST, Fabian Hueske wrote: 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 : 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 & RegardsGaurav LuthraMob:- +91-9901945206
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 < gauravluthra6...@gmail.com>: > 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 >
Need the way to create custom metrics
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
