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 {