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)
