This is an automated email from the ASF dual-hosted git repository. jiangtian pushed a commit to branch force_ci/support_schema_evolution in repository https://gitbox.apache.org/repos/asf/iotdb.git
commit 5887fa7c90a875e347839f4ceb3b3eda0b0e4bcf Author: Tian Jiang <[email protected]> AuthorDate: Tue Jan 13 16:57:51 2026 +0800 Update EvolvedSchemaCache --- .../dataregion/tsfile/evolution/EvolvedSchemaCache.java | 6 +----- .../iotdb/db/storageengine/dataregion/tsfile/fileset/TsFileSet.java | 2 +- 2 files changed, 2 insertions(+), 6 deletions(-) diff --git a/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/storageengine/dataregion/tsfile/evolution/EvolvedSchemaCache.java b/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/storageengine/dataregion/tsfile/evolution/EvolvedSchemaCache.java index 13188395e2d..7e15ea583d7 100644 --- a/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/storageengine/dataregion/tsfile/evolution/EvolvedSchemaCache.java +++ b/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/storageengine/dataregion/tsfile/evolution/EvolvedSchemaCache.java @@ -9,7 +9,7 @@ import org.checkerframework.checker.nullness.qual.Nullable; public class EvolvedSchemaCache { - private Cache<TsFileSet, EvolvedSchema> cache; + private final Cache<TsFileSet, EvolvedSchema> cache; private EvolvedSchemaCache() { cache = Caffeine.newBuilder().weigher( @@ -23,10 +23,6 @@ public class EvolvedSchemaCache { ).build(); } - public void put(TsFileSet tsFileSet, EvolvedSchema schema) { - cache.put(tsFileSet, schema); - } - public @Nullable EvolvedSchema computeIfAbsent(TsFileSet tsFileSet, Supplier<EvolvedSchema> schemaSupplier) { return cache.get(tsFileSet, k -> schemaSupplier.get()); } diff --git a/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/storageengine/dataregion/tsfile/fileset/TsFileSet.java b/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/storageengine/dataregion/tsfile/fileset/TsFileSet.java index af53868a771..e255afb8445 100644 --- a/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/storageengine/dataregion/tsfile/fileset/TsFileSet.java +++ b/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/storageengine/dataregion/tsfile/fileset/TsFileSet.java @@ -35,7 +35,7 @@ import org.apache.tsfile.utils.RamUsageEstimator; /** TsFileSet represents a set of TsFiles in a time partition whose version <= endVersion. */ public class TsFileSet implements Comparable<TsFileSet> { - + public static final String FILE_SET_DIR_NAME = "filesets"; private final long endVersion;
