Hi Hequn, thanks for drafting the FLIP and kicking off the discussion. +1 for this feature. I think this feature will be extremely convenient for PyFlink users.
Best, Xingbo Hequn Cheng <he...@apache.org> 于2020年3月9日周一 上午11:32写道： > Hi everyone, > > FLIP-58 adds the support for Python UDFs, but user-defined metrics > have not been supported yet. With metrics, users can report and monitor > the UDF status to get a deeper understanding of the execution, > so in this FLIP, we want to support metrics for Python UDFs. > > Previously, Jincheng and I discussed offline about the support of > metrics for Python UDFs. We'd like to achieve three goals for > supporting metrics for Python UDFs: > - Support user-defined metrics including Counters, Gauges, Meters, > Distributions in Python UDFs. > - Support defining user scopes. > - Support defining user variables. > > More details can be found in the FLIP wiki page[1] and we are looking > forward > to your feedback. > > Best, > Hequn > > [1] > > https://cwiki.apache.org/confluence/display/FLINK/FLIP-112%3A+Support+User-Defined+Metrics+in++Python+UDF >
