flink-user mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From Fabian Hueske <fhue...@gmail.com>
Subject Re: Need the way to create custom metrics
Date Wed, 19 Dec 2018 06:04:22 GMT

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


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 & Regards
> Gaurav Luthra
> Mob:- +91-9901945206

View raw message