This is an automated email from the ASF dual-hosted git repository.
jiangtian pushed a change to branch force_ci/support_schema_evolution
in repository https://gitbox.apache.org/repos/asf/iotdb.git
from a7dd10210a0 Add execution of EvolveSchemaNode
new 5e680e087d0 Evolve schema in FileLoaderUtils
new 67bc84578ae add EvolvedSchema.toSchemaEvolutions
new 5f64c454499 support delete with sevo
new 10a555360a4 support load with sevo
The 4 revisions listed above as "new" are entirely new to this
repository and will be described in separate emails. The revisions
listed as "add" were already present in the repository and have only
been added to this reference.
Summary of changes:
.../relational/it/db/it/IoTDBLoadTsFileIT.java | 73 +++++-
.../consensus/iot/client/DispatchLogHandler.java | 2 +-
.../impl/DataNodeInternalRPCServiceImpl.java | 4 +-
.../execution/operator/source/FileLoaderUtils.java | 12 +-
.../db/queryengine/plan/analyze/AnalyzeUtils.java | 39 +--
.../plan/analyze/load/LoadTsFileAnalyzer.java | 32 ++-
.../plan/planner/LogicalPlanVisitor.java | 3 +-
.../plan/node/load/LoadSingleTsFileNode.java | 15 +-
.../planner/plan/node/load/LoadTsFileNode.java | 15 +-
.../plan/relational/planner/RelationPlanner.java | 6 +-
.../plan/relational/sql/ast/LoadTsFile.java | 6 +
.../plan/scheduler/load/LoadTsFileScheduler.java | 4 +-
.../plan/statement/crud/LoadTsFileStatement.java | 6 +
.../db/storageengine/dataregion/DataRegion.java | 185 +++++++-------
.../compaction/execute/utils/CompactionUtils.java | 2 +-
.../dataregion/modification/DeletionPredicate.java | 40 +--
.../{IDPredicate.java => TagPredicate.java} | 55 +++--
.../dataregion/tsfile/evolution/ColumnRename.java | 1 +
.../dataregion/tsfile/evolution/EvolvedSchema.java | 219 ++++++++++++++---
.../tsfile/evolution/SchemaEvolutionFile.java | 4 +
.../dataregion/tsfile/fileset/TsFileSet.java | 4 +-
.../file/UnsealedTsFileRecoverPerformer.java | 2 +-
.../load/config/LoadTsFileConfigurator.java | 18 ++
.../load/splitter/AlignedChunkData.java | 13 +-
.../storageengine/load/splitter/DeletionData.java | 8 +-
.../load/splitter/NonAlignedChunkData.java | 11 +-
.../db/storageengine/load/splitter/TsFileData.java | 3 +
.../load/splitter/TsFileSplitter.java | 50 +++-
.../iotdb/db/metadata/path/PatternTreeMapTest.java | 2 +-
.../db/pipe/consensus/DeletionRecoverTest.java | 2 +-
.../db/pipe/consensus/DeletionResourceTest.java | 2 +-
.../PipePlanTablePatternParseVisitorTest.java | 8 +-
.../plan/planner/node/load/LoadTsFileNodeTest.java | 2 +-
.../node/write/RelationalDeleteDataNodeTest.java | 8 +-
.../storageengine/dataregion/DataRegionTest.java | 271 ++++++++++++++++-----
.../BatchedCompactionWithTsFileSplitterTest.java | 3 +-
.../tablemodel/CompactionWithAllNullRowsTest.java | 12 +-
.../modification/ModificationFileTest.java | 6 +-
.../modification/TableDeletionEntryTest.java | 8 +-
.../tsfile/evolution/EvolvedSchemaTest.java | 18 ++
40 files changed, 884 insertions(+), 290 deletions(-)
rename
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/storageengine/dataregion/modification/{IDPredicate.java
=> TagPredicate.java} (87%)
