[ https://issues.apache.org/jira/browse/FLINK-11198?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ]
Flink Jira Bot reassigned FLINK-11198: -------------------------------------- Assignee: (was: Hequn Cheng) > 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: API / DataStream > Affects Versions: 1.6.2 > Reporter: Chirag Dewan > Priority: Major > Labels: auto-unassigned > > 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 (v8.3.4#803005)