Versions Compared

Old Version 7

changes.mady.by.user Hequn Cheng

Saved on

compared with

New Version Current

changes.mady.by.user Chesnay Schepler

Saved on

Key

  • This line was added.
  • This line was removed.
  • Formatting was changed.

Status

Current state: ["Under Discussion"]

Discussion thread:  http://apache-flink-mailing-list-archive.1008284.n3.nabble.com/DISCUSS-FLIP-112-Support-User-Defined-Metrics-for-Python-UDF-td38609.html

JIRA: 

...

Page properties


Discussion thread
Vote thread
JIRA

Jira
serverASF JIRA
columnskey,summary,type,created,updated,due,assignee,reporter,priority,status,resolution
serverId5aa69414-a9e9-3523-82ec-879b028fb15b
keyFLINK-16670

Release1.11



Please keep the discussion on the mailing list rather than commenting on the wiki (wiki discussions get unwieldy fast).

...

A `get_metric_group` will be added to the FunctionContext class.

class FunctionContext(object):

    """

    Used to obtain global runtime information about the context in which the

    user-defined function is executed. The information includes the metric group,

    and global job parameters, etc.

    """


    def get_metric_group(self) -> MetricGroup:

        pass

Implementation Plan

  1. Transmit metric group information from Java to Python
  2. Support define scopes and variables on Python metric group
  3. Support Counter/Gauge/Distribution metric type for Python UDF
  4. Support Meter metric type for Python UDF
  5. Support Metrics for UDTF