Uploaded image for project: 'Flink'
  1. Flink
  2. FLINK-11198

Access to MetricGroup in an AggregateFunction(Non Rich)

    Details

    • Type: New Feature
    • Status: Open
    • Priority: Major
    • Resolution: Unresolved
    • Affects Version/s: 1.6.2
    • Fix Version/s: None
    • Component/s: API / DataStream
    • Labels:
      None

      Description

      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? 

        Attachments

          Issue Links

            Activity

              People

              • Assignee:
                hequn8128 Hequn Cheng
                Reporter:
                chiggi_dev Chirag Dewan
              • Votes:
                0 Vote for this issue
                Watchers:
                4 Start watching this issue

                Dates

                • Created:
                  Updated: