[
https://issues.apache.org/jira/browse/FLINK-11198?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16724959#comment-16724959
]
Hequn Cheng commented on FLINK-11198:
-------------------------------------
[~chiggi_dev] Thanks for opening the issue. It would be nice if make metrics
accessible from AggregateFunction. However, we should find a neat way to do
this.
> 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
> Assignee: Hequn Cheng
> Priority: Major
>
> 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)
