use Wrapped

Author: ThorneANN

…sink/v2/metrics/WrapperFlussCounter.java …sink/v2/metrics/WrappedFlussCounter.javaflink-cdc-connect/flink-cdc-pipeline-connectors/flink-cdc-pipeline-connector-fluss/src/main/java/org/apache/flink/cdc/connectors/fluss/sink/v2/metrics/WrapperFlussCounter.java renamed to flink-cdc-connect/flink-cdc-pipeline-connectors/flink-cdc-pipeline-connector-fluss/src/main/java/org/apache/flink/cdc/connectors/fluss/sink/v2/metrics/WrappedFlussCounter.java flink-cdc-connect/flink-cdc-pipeline-connectors/flink-cdc-pipeline-connector-fluss/src/main/java/org/apache/flink/cdc/connectors/fluss/sink/v2/metrics/WrapperFlussCounter.java renamed to flink-cdc-connect/flink-cdc-pipeline-connectors/flink-cdc-pipeline-connector-fluss/src/main/java/org/apache/flink/cdc/connectors/fluss/sink/v2/metrics/WrappedFlussCounter.java

@@ -24,11 +24,11 @@
  * additional information regarding copyright ownership. */
 
 /** An implementation of Flink's {@link Counter} which wraps Fluss's Counter. */
-public class WrapperFlussCounter implements Counter {
+public class WrappedFlussCounter implements Counter {
 
     private final com.alibaba.fluss.metrics.Counter flussCounter;
 
-    public WrapperFlussCounter(com.alibaba.fluss.metrics.Counter flussCounter) {
+    public WrappedFlussCounter(com.alibaba.fluss.metrics.Counter flussCounter) {
         this.flussCounter = flussCounter;
     }
 

…s/sink/v2/metrics/WrapperFlussGauge.java …s/sink/v2/metrics/WrappedFlussGauge.javaflink-cdc-connect/flink-cdc-pipeline-connectors/flink-cdc-pipeline-connector-fluss/src/main/java/org/apache/flink/cdc/connectors/fluss/sink/v2/metrics/WrapperFlussGauge.java renamed to flink-cdc-connect/flink-cdc-pipeline-connectors/flink-cdc-pipeline-connector-fluss/src/main/java/org/apache/flink/cdc/connectors/fluss/sink/v2/metrics/WrappedFlussGauge.java flink-cdc-connect/flink-cdc-pipeline-connectors/flink-cdc-pipeline-connector-fluss/src/main/java/org/apache/flink/cdc/connectors/fluss/sink/v2/metrics/WrapperFlussGauge.java renamed to flink-cdc-connect/flink-cdc-pipeline-connectors/flink-cdc-pipeline-connector-fluss/src/main/java/org/apache/flink/cdc/connectors/fluss/sink/v2/metrics/WrappedFlussGauge.java

@@ -24,11 +24,11 @@
  * additional information regarding copyright ownership. */
 
 /** An implementation of Flink's {@link Gauge} which wraps Fluss's Gauge. */
-public class WrapperFlussGauge<T> implements Gauge<T> {
+public class WrappedFlussGauge<T> implements Gauge<T> {
 
     private final com.alibaba.fluss.metrics.Gauge<T> flussGauge;
 
-    public WrapperFlussGauge(com.alibaba.fluss.metrics.Gauge<T> flussGauge) {
+    public WrappedFlussGauge(com.alibaba.fluss.metrics.Gauge<T> flussGauge) {
         this.flussGauge = flussGauge;
     }
 

flink-cdc-connect/flink-cdc-pipeline-connectors/flink-cdc-pipeline-connector-fluss/src/main/java/org/apache/flink/cdc/connectors/fluss/sink/v2/metrics/WrapperFlussMetricRegistry.java

@@ -116,13 +116,13 @@ private Map<String, String> getVariables(AbstractMetricGroup group) {
     private void registerMetric(MetricGroup metricGroup, Metric metric, String metricName) {
         switch (metric.getMetricType()) {
             case COUNTER:
-                metricGroup.counter(metricName, new WrapperFlussCounter((Counter) metric));
+                metricGroup.counter(metricName, new WrappedFlussCounter((Counter) metric));
                 break;
             case METER:
                 metricGroup.meter(metricName, new WrapperFlussMeter((Meter) metric));
                 break;
             case GAUGE:
-                metricGroup.gauge(metricName, new WrapperFlussGauge<>((Gauge<?>) metric));
+                metricGroup.gauge(metricName, new WrappedFlussGauge<>((Gauge<?>) metric));
                 break;
             case HISTOGRAM:
                 metricGroup.histogram(metricName, new WrapperFlussHistogram((Histogram) metric));