Update PipeDataNodeRemainingEventAndTimeMetrics.java

apache · Oct 21, 2024 · 7878f41 · 7878f41
1 parent fdcb560
commit 7878f41
Showing 1 changed file with 0 additions and 12 deletions.
diff --git a/...c/main/java/org/apache/iotdb/db/pipe/metric/PipeDataNodeRemainingEventAndTimeMetrics.java b/...c/main/java/org/apache/iotdb/db/pipe/metric/PipeDataNodeRemainingEventAndTimeMetrics.java
@@ -165,18 +165,6 @@ public void decreaseHeartbeatEventCount(final String pipeID) {
         .decreaseHeartbeatEventCount();
   }
 
-  public void increaseSchemaRegionEventCount(final String pipeID) {
-    if (remainingEventAndTimeOperatorMap.containsKey(pipeID)) {
-      remainingEventAndTimeOperatorMap.get(pipeID).increaseSchemaRegionEventCount();
-    }
-  }
-
-  public void decreaseSchemaRegionEventCount(final String pipeID) {
-    if (remainingEventAndTimeOperatorMap.containsKey(pipeID)) {
-      remainingEventAndTimeOperatorMap.get(pipeID).decreaseSchemaRegionEventCount();
-    }
-  }
-
   public void thawRate(final String pipeID) {
     if (!remainingEventAndTimeOperatorMap.containsKey(pipeID)) {
       // In dataNode, the "thawRate" may be called when there are no subtasks, and we call