src/jvm/backtype/storm/metric/api/CountMetric.java

package backtype.storm.metric.api;

import backtype.storm.metric.api.IMetric;

public class CountMetric implements IMetric {
    long _value = 0;

    public CountMetric() {
    }
    
    public void incr() {
        _value++;
    }

    public void incrBy(long incrementBy) {
        _value += incrementBy;
    }

    public Object getValueAndReset() {
        long ret = _value;
        _value = 0;
        return ret;
    }
}