本文主要是介绍Flink实战（七十一）：监控（三）自定义metrics相关指标（一），希望对大家解决编程问题提供一定的参考价值，需要的开发者们随着小编来一起学习吧！
0 简介
User-defined Metrics
除了系统的 Metrics 之外，Flink 支持自定义 Metrics ，即 User-defined Metrics。上文说的都是系统框架方面，对于自己的业务逻辑也可以用 Metrics 来暴露一些指标，以便进行监控。
User-defined Metrics 现在提及的都是 datastream 的 API，table、sql 可能需要 context 协助，但如果写 UDF，它们其实是大同小异的。
Datastream 的 API 是继承 RichFunction ，继承 RichFunction 才可以有 Metrics 的接口。然后通过 RichFunction 会带来一个 getRuntimeContext().getMetricGroup().addGroup(…) 的方法，这里就是 User-defined Metrics 的入口。通过这种方式，可以自定义 user-defined Metric Group。如果想定义具体的 Metrics，同样需要用getRuntimeContext().getMetricGroup().counter/gauge/meter/histogram(…) 方法，它会有相应的构造函数，可以定义到自己的 Metrics 类型中。
继承 RichFunction•Register user-defined Metric Group: 这篇关于Flink实战（七十一）：监控（三）自定义metrics相关指标（一）的文章就介绍到这儿，希望我们推荐的文章对编程师们有所帮助！
