fluss-flink/fluss-flink-common/src/main/java/com/alibaba/fluss/flink/metrics/FlinkMeter.java [22:47]:
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -
public class FlinkMeter implements Meter {

    private final com.alibaba.fluss.metrics.Meter wrapped;

    public FlinkMeter(com.alibaba.fluss.metrics.Meter wrapped) {
        this.wrapped = wrapped;
    }

    @Override
    public void markEvent() {
        wrapped.markEvent();
    }

    @Override
    public void markEvent(long n) {
        wrapped.markEvent(n);
    }

    @Override
    public double getRate() {
        return wrapped.getRate();
    }

    @Override
    public long getCount() {
        return wrapped.getCount();
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -



fluss-lakehouse/fluss-lakehouse-paimon/src/main/java/com/alibaba/fluss/lakehouse/paimon/source/metrics/FlinkMeter.java [22:47]:
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -
public class FlinkMeter implements Meter {

    private final com.alibaba.fluss.metrics.Meter wrapped;

    public FlinkMeter(com.alibaba.fluss.metrics.Meter wrapped) {
        this.wrapped = wrapped;
    }

    @Override
    public void markEvent() {
        wrapped.markEvent();
    }

    @Override
    public void markEvent(long n) {
        wrapped.markEvent(n);
    }

    @Override
    public double getRate() {
        return wrapped.getRate();
    }

    @Override
    public long getCount() {
        return wrapped.getCount();
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -