Need the way to create custom metrics

[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 

[Fabian Hueske-2]

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 <[hidden email]>:

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 

[chiggi_dev]

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 <[hidden email]> 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 <[hidden email]>:

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