(iotdb) branch table_disk_usage_statistics_with_cache updated: refactor

[shuwenwei]

This is an automated email from the ASF dual-hosted git repository.

shuwenwei pushed a commit to branch table_disk_usage_statistics_with_cache
in repository https://gitbox.apache.org/repos/asf/iotdb.git


The following commit(s) were added to 
refs/heads/table_disk_usage_statistics_with_cache by this push:
     new c3945c6ff93 refactor
c3945c6ff93 is described below

commit c3945c6ff93cf0620fe6f78e531793d40a53a743
Author: shuwenwei <s13979062...@gmail.com>
AuthorDate: Thu Jan 22 10:25:43 2026 +0800

    refactor
---
 .../tableDiskUsageCache/TableDiskUsageCache.java   | 44 +++++++++++-----------
 1 file changed, 21 insertions(+), 23 deletions(-)

diff --git 
a/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/storageengine/dataregion/utils/tableDiskUsageCache/TableDiskUsageCache.java
 
b/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/storageengine/dataregion/utils/tableDiskUsageCache/TableDiskUsageCache.java
index e586e35ca35..981b7bef4d8 100644
--- 
a/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/storageengine/dataregion/utils/tableDiskUsageCache/TableDiskUsageCache.java
+++ 
b/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/storageengine/dataregion/utils/tableDiskUsageCache/TableDiskUsageCache.java
@@ -107,7 +107,7 @@ public class TableDiskUsageCache {
   }
 
   public void writeObjectDelta(
-      String database, int regionId, long timePartition, Map<String, Long> 
tableObjectDeltaMap) {
+      String database, int regionId, long timePartition, String table, long 
size, int num) {
     throw new UnsupportedOperationException();
   }
 
@@ -151,6 +151,22 @@ public class TableDiskUsageCache {
     return new DataRegionTableSizeCacheWriter(database, regionId);
   }
 
+  protected TsFileTableSizeCacheReader createTsFileCacheReader(
+      DataRegionTableSizeCacheWriter dataRegionWriter, int regionId) {
+    TsFileTableDiskUsageCacheWriter tsFileCacheWriter = 
dataRegionWriter.tsFileCacheWriter;
+    return new TsFileTableSizeCacheReader(
+        tsFileCacheWriter.keyFileLength(),
+        tsFileCacheWriter.getKeyFile(),
+        tsFileCacheWriter.valueFileLength(),
+        tsFileCacheWriter.getValueFile(),
+        regionId);
+  }
+
+  protected IObjectTableSizeCacheReader createObjectFileCacheReader(
+      DataRegionTableSizeCacheWriter dataRegionWriter, int regionId) {
+    return new EmptyObjectTableSizeCacheReader();
+  }
+
   protected abstract static class Operation {
     protected final String database;
     protected final int regionId;
@@ -198,34 +214,16 @@ public class TableDiskUsageCache {
         writer.flush();
         writer.increaseActiveReaderNum();
         TsFileTableSizeCacheReader tsFileTableSizeCacheReader =
-            readTsFileCache ? createTsFileCacheReader(writer) : null;
+            readTsFileCache ? 
tableDiskUsageCache.createTsFileCacheReader(writer, regionId) : null;
         IObjectTableSizeCacheReader objectTableSizeCacheReader =
-            readObjectFileCache ? createObjectFileCacheReader(writer) : null;
+            readObjectFileCache
+                ? tableDiskUsageCache.createObjectFileCacheReader(writer, 
regionId)
+                : null;
         future.complete(new Pair<>(tsFileTableSizeCacheReader, 
objectTableSizeCacheReader));
       } catch (Throwable t) {
         future.completeExceptionally(t);
       }
     }
-
-    protected TsFileTableSizeCacheReader createTsFileCacheReader(
-        DataRegionTableSizeCacheWriter dataRegionWriter) {
-      TsFileTableDiskUsageCacheWriter tsFileCacheWriter = 
dataRegionWriter.tsFileCacheWriter;
-      if (readTsFileCache) {
-        return new TsFileTableSizeCacheReader(
-            tsFileCacheWriter.keyFileLength(),
-            tsFileCacheWriter.getKeyFile(),
-            tsFileCacheWriter.valueFileLength(),
-            tsFileCacheWriter.getValueFile(),
-            regionId);
-      }
-      return new TsFileTableSizeCacheReader(
-          0, tsFileCacheWriter.getKeyFile(), 0, 
tsFileCacheWriter.getValueFile(), regionId);
-    }
-
-    protected IObjectTableSizeCacheReader createObjectFileCacheReader(
-        DataRegionTableSizeCacheWriter dataRegionWriter) {
-      return new EmptyObjectTableSizeCacheReader();
-    }
   }
 
   private static class EndReadOperation extends Operation {