Hi, I was working on the creating new Meter metric type, but I need some input to define a proper interface for it. Initial idea developed in this pull request [1] was to follow Dropwizard's meter interface, but zentol suggested that we may need a different interface for Flink use-cases. The issue with Dropwizard Meter interface is that it only supports 1, 5, and 15 minutes rates, while we may need different rates (e.g. sub-minute rate) or may not need one of these rates.
I think that a way to implement a flexible Meter type would be by adding two methods: List<Double> getRates() // returns a list of rates a Meter supports, e.g. {1, 5, 15} would mean that a particular Meter supports 1, 5, and 15 minutes rates double getRate(double rate) // get moving average for provided rate What do you think about it? Best regards, Ivan. [1] - https://github.com/apache/flink/pull/2374