fluss-flink/fluss-flink-common/src/main/java/com/alibaba/fluss/flink/metrics/FlinkHistogram.java [23:89]:
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -
public class FlinkHistogram implements Histogram {

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

    public FlinkHistogram(com.alibaba.fluss.metrics.Histogram wrapped) {
        this.wrapped = wrapped;
    }

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

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

    @Override
    public HistogramStatistics getStatistics() {

        wrapped.getStatistics();

        return null;
    }

    private static class FlinkHistogramStatistics extends HistogramStatistics {

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

        public FlinkHistogramStatistics(com.alibaba.fluss.metrics.HistogramStatistics wrapped) {
            this.wrapped = wrapped;
        }

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

        @Override
        public long[] getValues() {
            return wrapped.getValues();
        }

        @Override
        public int size() {
            return wrapped.size();
        }

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

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

        @Override
        public long getMax() {
            return wrapped.getMax();
        }

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



fluss-lakehouse/fluss-lakehouse-paimon/src/main/java/com/alibaba/fluss/lakehouse/paimon/source/metrics/FlinkHistogram.java [23:89]:
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -
public class FlinkHistogram implements Histogram {

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

    public FlinkHistogram(com.alibaba.fluss.metrics.Histogram wrapped) {
        this.wrapped = wrapped;
    }

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

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

    @Override
    public HistogramStatistics getStatistics() {

        wrapped.getStatistics();

        return null;
    }

    private static class FlinkHistogramStatistics extends HistogramStatistics {

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

        public FlinkHistogramStatistics(com.alibaba.fluss.metrics.HistogramStatistics wrapped) {
            this.wrapped = wrapped;
        }

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

        @Override
        public long[] getValues() {
            return wrapped.getValues();
        }

        @Override
        public int size() {
            return wrapped.size();
        }

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

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

        @Override
        public long getMax() {
            return wrapped.getMax();
        }

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