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 71a6633713c add methods
71a6633713c is described below

commit 71a6633713cc1b30a2c0f2d975f0fc0879133bea
Author: shuwenwei <[email protected]>
AuthorDate: Mon Jan 26 12:01:08 2026 +0800

    add methods
---
 .../utils/tableDiskUsageCache/TableDiskUsageCache.java       | 12 ++++++++++++
 1 file changed, 12 insertions(+)

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 e748f19a152..0a5f44e30d2 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
@@ -206,6 +206,14 @@ public class TableDiskUsageCache {
       this.regionId = regionId;
     }
 
+    public int getRegionId() {
+      return regionId;
+    }
+
+    public String getDatabase() {
+      return database;
+    }
+
     public abstract void apply(TableDiskUsageCache tableDiskUsageCache) throws 
IOException;
   }
 
@@ -337,6 +345,10 @@ public class TableDiskUsageCache {
           regionId, regionId -> tableDiskUsageCache.createWriter(database, 
regionId));
       future.complete(null);
     }
+
+    public CompletableFuture<Void> getFuture() {
+      return future;
+    }
   }
 
   private static class RemoveRegionOperation extends Operation {

Reply via email to