本文主要是介绍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相关指标(一)的文章就介绍到这儿,希望我们推荐的文章对编程师们有所帮助!