You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@iotdb.apache.org by ro...@apache.org on 2025/03/26 12:51:28 UTC
(iotdb) 03/03: Update PipeDataNodeMetrics.java
This is an automated email from the ASF dual-hosted git repository.
rong pushed a commit to branch tsfile-2-tablet-metrics
in repository https://gitbox.apache.org/repos/asf/iotdb.git
commit 3ec8eabc16dfb517f5017614b926fe53980f26fd
Author: Steve Yurong Su <ro...@apache.org>
AuthorDate: Wed Mar 26 20:51:17 2025 +0800
Update PipeDataNodeMetrics.java
---
.../main/java/org/apache/iotdb/db/pipe/metric/PipeDataNodeMetrics.java | 3 +++
1 file changed, 3 insertions(+)
diff --git a/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/metric/PipeDataNodeMetrics.java b/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/metric/PipeDataNodeMetrics.java
index 004b1bccf77..3f03ce580fd 100644
--- a/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/metric/PipeDataNodeMetrics.java
+++ b/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/metric/PipeDataNodeMetrics.java
@@ -23,6 +23,7 @@ import org.apache.iotdb.commons.pipe.metric.PipeEventCommitMetrics;
import org.apache.iotdb.db.pipe.metric.overview.PipeDataNodeRemainingEventAndTimeMetrics;
import org.apache.iotdb.db.pipe.metric.overview.PipeHeartbeatEventMetrics;
import org.apache.iotdb.db.pipe.metric.overview.PipeResourceMetrics;
+import org.apache.iotdb.db.pipe.metric.overview.PipeTsFileToTabletsMetrics;
import org.apache.iotdb.db.pipe.metric.overview.PipeWALInsertNodeCacheMetrics;
import org.apache.iotdb.db.pipe.metric.processor.PipeProcessorMetrics;
import org.apache.iotdb.db.pipe.metric.receiver.PipeDataNodeReceiverMetrics;
@@ -54,6 +55,7 @@ public class PipeDataNodeMetrics implements IMetricSet {
PipeSchemaRegionConnectorMetrics.getInstance().bindTo(metricService);
PipeDataNodeRemainingEventAndTimeMetrics.getInstance().bindTo(metricService);
PipeDataNodeReceiverMetrics.getInstance().bindTo(metricService);
+ PipeTsFileToTabletsMetrics.getInstance().bindTo(metricService);
}
@Override
@@ -71,6 +73,7 @@ public class PipeDataNodeMetrics implements IMetricSet {
PipeSchemaRegionConnectorMetrics.getInstance().unbindFrom(metricService);
PipeDataNodeRemainingEventAndTimeMetrics.getInstance().unbindFrom(metricService);
PipeDataNodeReceiverMetrics.getInstance().unbindFrom(metricService);
+ PipeTsFileToTabletsMetrics.getInstance().unbindFrom(metricService);
}
//////////////////////////// singleton ////////////////////////////