You are viewing a plain text version of this content. The canonical link for it is here.

Posted to dev@flink.apache.org by "Chirag Dewan (JIRA)" <ji...@apache.org> on 2018/12/19 07:07:00 UTC

[jira] [Created] (FLINK-11198) Access to MetricGroup in an AggregateFunction(Non Rich)

Chirag Dewan created FLINK-11198:
------------------------------------

             Summary: Access to MetricGroup in an AggregateFunction(Non Rich)
                 Key: FLINK-11198
                 URL: https://issues.apache.org/jira/browse/FLINK-11198
             Project: Flink
          Issue Type: New Feature
          Components: DataStream API
    Affects Versions: 1.6.2
            Reporter: Chirag Dewan
             Fix For: 1.6.3


The only way to add custom metrics from UDF is through RuntimeContext. And, RuntimeContext is wired in every RichFunction implementation.

However, for aggregate() in Windowed Stream, we cannot use the Rich version of AggregateFunction. As I remotely understand, is done to avoid exposing the state in the Aggregate UDF. 

But can we have some minimal context which does not expose state but provide metrics, classloader etc.in the UDF? 



--
This message was sent by Atlassian JIRA
(v7.6.3#76005)