fluss-flink/fluss-flink-common/src/main/java/com/alibaba/fluss/flink/metrics/FlinkCounter.java [22:52]:
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -
public class FlinkCounter implements Counter {

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

    public FlinkCounter(com.alibaba.fluss.metrics.Counter wrapped) {
        this.wrapped = wrapped;
    }

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

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

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

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

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



fluss-lakehouse/fluss-lakehouse-paimon/src/main/java/com/alibaba/fluss/lakehouse/paimon/source/metrics/FlinkCounter.java [22:52]:
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -
public class FlinkCounter implements Counter {

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

    public FlinkCounter(com.alibaba.fluss.metrics.Counter wrapped) {
        this.wrapped = wrapped;
    }

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

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

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

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

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