This is an automated email from the ASF dual-hosted git repository. jlli pushed a commit to branch add-count-method-in-pinot-meter in repository https://gitbox.apache.org/repos/asf/incubator-pinot.git
commit c959010af3878e68ed5c2523d58d28b769f5672c Author: Jack Li(Analytics Engineering) <[email protected]> AuthorDate: Sat Feb 27 17:35:53 2021 -0800 Add count method in PinotMeter interface --- .../java/org/apache/pinot/common/metrics/yammer/YammerMeter.java | 5 +++++ pinot-spi/src/main/java/org/apache/pinot/spi/metrics/PinotMeter.java | 2 ++ 2 files changed, 7 insertions(+) diff --git a/pinot-common/src/main/java/org/apache/pinot/common/metrics/yammer/YammerMeter.java b/pinot-common/src/main/java/org/apache/pinot/common/metrics/yammer/YammerMeter.java index d480b43..a2616f3 100644 --- a/pinot-common/src/main/java/org/apache/pinot/common/metrics/yammer/YammerMeter.java +++ b/pinot-common/src/main/java/org/apache/pinot/common/metrics/yammer/YammerMeter.java @@ -36,6 +36,11 @@ public class YammerMeter extends YammerMetered implements PinotMeter { } @Override + public long count() { + return _meter.count(); + } + + @Override public Object getMetric() { return _meter; } diff --git a/pinot-spi/src/main/java/org/apache/pinot/spi/metrics/PinotMeter.java b/pinot-spi/src/main/java/org/apache/pinot/spi/metrics/PinotMeter.java index f7b9c94..a3bc4a4 100644 --- a/pinot-spi/src/main/java/org/apache/pinot/spi/metrics/PinotMeter.java +++ b/pinot-spi/src/main/java/org/apache/pinot/spi/metrics/PinotMeter.java @@ -27,4 +27,6 @@ package org.apache.pinot.spi.metrics; public interface PinotMeter { void mark(final long unitCount); + + long count(); } --------------------------------------------------------------------- To unsubscribe, e-mail: [email protected] For additional commands, e-mail: [email protected]
