Я использую Prometheus для мониторинга приложения, которое я развернул на кластере Flink. До сих пор я могу запросить Codahale/DropWizard
, который я создал. Тем не менее, я знаю, что у них также есть некоторые методы, которые я мог бы лучше понять данные. Например, Meter имеет много методов, и до сих пор я могу только запросить счетчик, который я зарегистрировал. Как я могу запросить методы count
, mark()
или meanRate()
?
public class StationPlatformMapper extends RichMapFunction<MqttSensor, Tuple2<CompositeKeyStationPlatform, MqttSensor>> {
private transient Meter meter;
public void open(Configuration config) throws Exception {
com.codahale.metrics.Meter dropwizardMeter = new com.codahale.metrics.Meter();
this.meter = getRuntimeContext().getMetricGroup().meter(StationPlatformMapper.class.getSimpleName() + "-meter", new DropwizardMeterWrapper(dropwizardMeter));
}
public Tuple2<CompositeKeyStationPlatform, MqttSensor> map(MqttSensor value) throws Exception {
this.meter.markEvent();
return Tuple2.of(compositeKey, value);
}
}