在一个 flink operator 中怎样根据消息内容动态生成多个监控指标？

Thu, 02 Jul 2020 00:35:08 -0700 

官网上的例子：

public class MyMapper extends RichMapFunction<String, String> {
  private transient Counter counter;
  @Override
  public void open(Configuration config) {
    this.counter = getRuntimeContext()
      .getMetricGroup()
      .counter("myCounter");
  }
  @Override
  public String map(String value) throws Exception {
    this.counter.inc();
    return value;
  }
}

我想要根据 map 方法中传入的参数生成不同的 监控指标，怎样可以实现呢？

谢谢，
王磊



[email protected]

回复