Metric: Add pipe linked tsfile size and count metric (#14768)

* add linked tsfile size count

* fix review

Author: Pengzna

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

@@ -67,6 +67,11 @@ public void bindTo(final AbstractMetricService metricService) {
         MetricLevel.IMPORTANT,
         PipeDataNodeResourceManager.tsfile(),
         PipeTsFileResourceManager::getLinkedTsfileCount);
+    metricService.createAutoGauge(
+        Metric.PIPE_LINKED_TSFILE_SIZE.toString(),
+        MetricLevel.IMPORTANT,
+        PipeDataNodeResourceManager.tsfile(),
+        PipeTsFileResourceManager::getTotalLinkedTsfileSize);
     // phantom reference count
     metricService.createAutoGauge(
         Metric.PIPE_PHANTOM_REFERENCE_COUNT.toString(),
@@ -85,6 +90,7 @@ public void unbindFrom(final AbstractMetricService metricService) {
     // resource reference count
     metricService.remove(MetricType.AUTO_GAUGE, Metric.PIPE_PINNED_MEMTABLE_COUNT.toString());
     metricService.remove(MetricType.AUTO_GAUGE, Metric.PIPE_LINKED_TSFILE_COUNT.toString());
+    metricService.remove(MetricType.AUTO_GAUGE, Metric.PIPE_LINKED_TSFILE_SIZE.toString());
     // phantom reference count
     metricService.remove(MetricType.AUTO_GAUGE, Metric.PIPE_PHANTOM_REFERENCE_COUNT.toString());
   }

iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/resource/tsfile/PipeTsFileResourceManager.java

@@ -166,6 +166,7 @@ public File increaseFileReference(
           isTsFile
               ? FileUtils.createHardLink(file, hardlinkOrCopiedFile)
               : FileUtils.copyFile(file, hardlinkOrCopiedFile);
+
       // If the file is not a hardlink or copied file, and there is no related hardlink or copied
       // file in pipe dir, create a hardlink or copy it to pipe dir, maintain a reference count for
       // the hardlink or copied file, and return the hardlink or copied file.
@@ -335,6 +336,20 @@ public int getLinkedTsfileCount() {
     return hardlinkOrCopiedFileToPipeTsFileResourceMap.size();
   }
 
+  public long getTotalLinkedTsfileSize() {
+    return hardlinkOrCopiedFileToPipeTsFileResourceMap.values().stream()
+        .mapToLong(
+            resource -> {
+              try {
+                return resource.getFileSize();
+              } catch (Exception e) {
+                LOGGER.warn("failed to get file size of linked TsFile {}: ", resource, e);
+                return 0;
+              }
+            })
+        .sum();
+  }
+
   /**
    * Get the total size of linked TsFiles whose original TsFile is deleted (by compaction or else)
    */

iotdb-core/node-commons/src/main/java/org/apache/iotdb/commons/service/metric/enums/Metric.java

@@ -159,6 +159,7 @@ public enum Metric {
   PIPE_MEM("pipe_mem"),
   PIPE_PINNED_MEMTABLE_COUNT("pipe_pinned_memtable_count"),
   PIPE_LINKED_TSFILE_COUNT("pipe_linked_tsfile_count"),
+  PIPE_LINKED_TSFILE_SIZE("pipe_linked_tsfile_size"),
   PIPE_PHANTOM_REFERENCE_COUNT("pipe_phantom_reference_count"),
   PIPE_ASYNC_CONNECTOR_RETRY_EVENT_QUEUE_SIZE("pipe_async_connector_retry_event_queue_size"),
   PIPE_EVENT_COMMIT_QUEUE_SIZE("pipe_event_commit_queue_size"),