Flink SQL UDF 如何自定义Metrics

classic Classic list List threaded Threaded
1 message Options
Reply | Threaded
Open this post in threaded view
|

Flink SQL UDF 如何自定义Metrics

xingoo
HI,
 如题,想要在Flink
SQL中通过自定义UDF增加指标,从而实现自定义告警。那么如何在UDF中获取到RuntimeContext从而修改Metrics呢?



--
Sent from: http://apache-flink.147419.n8.nabble.com/