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 3a059a5caec fix compilation
new 1419259c741 suppor schema evolution in schema region
new 5fa3d205756 add more tests
new 9c2898b5c4a spotless
new 33dd195284b fix that copy of EvolvedSchema is not deep enough
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:
.../iotdb/relational/it/schema/IoTDBTableIT.java | 424 ++++++++++++++++++++-
.../client/async/CnToDnAsyncRequestType.java | 2 +
.../CnToDnInternalServiceAsyncRequestManager.java | 12 +
.../rpc/DataNodeAsyncRequestRPCHandler.java | 2 +
.../iotdb/confignode/manager/ConfigManager.java | 49 ++-
.../apache/iotdb/confignode/manager/IManager.java | 6 +
.../manager/partition/PartitionManager.java | 28 +-
.../manager/schema/ClusterSchemaManager.java | 11 +
.../schema/table/RenameTableColumnProcedure.java | 44 ++-
.../impl/schema/table/RenameTableProcedure.java | 70 +++-
.../state/schema/RenameTableColumnState.java | 1 +
.../procedure/state/schema/RenameTableState.java | 1 +
.../hash/DeviceGroupHashExecutorManualTest.java | 3 +-
.../schemaregion/SchemaExecutionVisitor.java | 12 +
.../impl/DataNodeInternalRPCServiceImpl.java | 20 +
.../plan/analyze/ClusterPartitionFetcher.java | 14 +-
.../analyze/cache/partition/PartitionCache.java | 8 +-
.../execution/config/TableConfigTaskVisitor.java | 50 ++-
.../plan/planner/distribution/SourceRewriter.java | 7 +-
.../planner/plan/node/write/EvolveSchemaNode.java | 21 +-
.../planner/plan/node/write/InsertRowNode.java | 3 +-
.../planner/plan/node/write/InsertRowsNode.java | 3 +-
.../plan/node/write/InsertRowsOfOneDeviceNode.java | 3 +-
.../planner/plan/node/write/InsertTabletNode.java | 5 +-
.../plan/node/write/RelationalInsertRowsNode.java | 7 +-
.../node/write/RelationalInsertTabletNode.java | 6 +-
.../distribute/TableDistributedPlanGenerator.java | 26 +-
.../node/schema/CreateOrUpdateTableDeviceNode.java | 8 +-
.../plan/relational/sql/ast/BooleanLiteral.java | 4 +
.../plan/relational/sql/ast/RenameColumn.java | 5 -
.../plan/relational/sql/ast/RenameTable.java | 5 -
.../plan/scheduler/load/LoadTsFileScheduler.java | 17 +-
.../schemaengine/schemaregion/ISchemaRegion.java | 3 +
.../schemaregion/SchemaRegionPlanType.java | 1 +
.../schemaregion/SchemaRegionPlanVisitor.java | 5 +
.../schemaregion/impl/SchemaRegionMemoryImpl.java | 38 +-
.../schemaregion/impl/SchemaRegionPBTreeImpl.java | 6 +
.../visitor/SchemaRegionPlanDeserializer.java | 7 +
.../visitor/SchemaRegionPlanSerializer.java | 7 +
.../mtree/impl/mem/MTreeBelowSGMemoryImpl.java | 10 +
.../write/req/SchemaRegionWritePlanFactory.java | 3 +
.../db/storageengine/dataregion/DataRegion.java | 10 +-
.../dataregion/tsfile/TsFileManager.java | 3 +-
.../dataregion/tsfile/TsFileResource.java | 4 +
.../dataregion/tsfile/evolution/EvolvedSchema.java | 12 +-
.../tsfile/evolution/SchemaEvolution.java | 8 +
.../org/apache/iotdb/db/utils/CommonUtils.java | 19 +
.../tsfile/evolution/EvolvedSchemaTest.java | 52 +++
.../iotdb/commons/partition/DataPartition.java | 59 +--
.../apache/iotdb/commons/partition/Partition.java | 7 +-
.../iotdb/commons/partition/SchemaPartition.java | 11 +-
.../executor/SeriesPartitionExecutor.java | 53 ++-
.../partition/executor/hash/APHashExecutor.java | 8 +-
.../partition/executor/hash/BKDRHashExecutor.java | 8 +-
.../partition/executor/hash/JSHashExecutor.java | 8 +-
.../partition/executor/hash/SDBMHashExecutor.java | 8 +-
.../apache/iotdb/commons/schema/table/TsTable.java | 12 +-
.../src/main/thrift/datanode.thrift | 8 +
58 files changed, 1103 insertions(+), 144 deletions(-)
