partial

Author: Caideyipi

iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/extractor/dataregion/realtime/assigner/PipeDataRegionAssigner.java

@@ -32,6 +32,7 @@
 import org.apache.iotdb.db.pipe.extractor.dataregion.realtime.PipeRealtimeDataRegionExtractor;
 import org.apache.iotdb.db.pipe.extractor.dataregion.realtime.matcher.CachedSchemaPatternMatcher;
 import org.apache.iotdb.db.pipe.extractor.dataregion.realtime.matcher.PipeDataRegionMatcher;
+import org.apache.iotdb.db.pipe.metric.source.PipeAssignerMetrics;
 import org.apache.iotdb.db.pipe.metric.source.PipeDataRegionEventCounter;
 
 import org.slf4j.Logger;
@@ -70,6 +71,7 @@ public PipeDataRegionAssigner(final String dataRegionId) {
     this.matcher = new CachedSchemaPatternMatcher();
     this.disruptor = new DisruptorQueue(this::assignToExtractor, this::onAssignedHook);
     this.dataRegionId = dataRegionId;
+    PipeAssignerMetrics.getInstance().register(this);
   }
 
   public void publishToAssign(final PipeRealtimeEvent event) {

iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/metric/PipeDataNodeMetrics.java

@@ -30,6 +30,7 @@
 import org.apache.iotdb.db.pipe.metric.schema.PipeSchemaRegionExtractorMetrics;
 import org.apache.iotdb.db.pipe.metric.schema.PipeSchemaRegionListenerMetrics;
 import org.apache.iotdb.db.pipe.metric.sink.PipeDataRegionConnectorMetrics;
+import org.apache.iotdb.db.pipe.metric.source.PipeAssignerMetrics;
 import org.apache.iotdb.db.pipe.metric.source.PipeDataRegionExtractorMetrics;
 import org.apache.iotdb.metrics.AbstractMetricService;
 import org.apache.iotdb.metrics.metricsets.IMetricSet;
@@ -40,6 +41,7 @@ public class PipeDataNodeMetrics implements IMetricSet {
 
   @Override
   public void bindTo(final AbstractMetricService metricService) {
+    PipeAssignerMetrics.getInstance().bindTo(metricService);
     PipeDataRegionExtractorMetrics.getInstance().bindTo(metricService);
     PipeProcessorMetrics.getInstance().bindTo(metricService);
     PipeDataRegionConnectorMetrics.getInstance().bindTo(metricService);
@@ -56,6 +58,7 @@ public void bindTo(final AbstractMetricService metricService) {
 
   @Override
   public void unbindFrom(final AbstractMetricService metricService) {
+    PipeAssignerMetrics.getInstance().unbindFrom(metricService);
     PipeDataRegionExtractorMetrics.getInstance().unbindFrom(metricService);
     PipeProcessorMetrics.getInstance().unbindFrom(metricService);
     PipeDataRegionConnectorMetrics.getInstance().unbindFrom(metricService);