This is an automated email from the ASF dual-hosted git repository.
justinchen pushed a change to branch err-cli-opti
in repository https://gitbox.apache.org/repos/asf/iotdb.git
from 1ce0f328326 fix
add 3ca20a3ce3f Alter column and timeseries datatype with ANSI SQL
statement (#16027)
add 366726f8259 Fixed the path check semantic for object (#16983)
add 283db33b319 Merge branch 'master' of https://github.com/apache/iotdb
into err-cli-opti
No new revisions were added by this update.
Summary of changes:
.../apache/iotdb/db/it/query/IoTDBResultSetIT.java | 11 +-
.../db/it/schema/IoTDBAlterTimeSeriesTypeIT.java | 2736 ++++++++++++++++++++
.../manual/enhanced/IoTDBPipeIdempotentIT.java | 8 +
.../manual/IoTDBPipeTypeConversionISessionIT.java | 10 +-
.../relational/it/db/it/IoTDBDeletionTableIT.java | 21 +
.../it/db/it/IoTDBSetSystemStatusTableIT.java | 1 +
.../it/schema/IoTDBAlterColumnTypeIT.java | 2349 +++++++++++++++++
.../iotdb/relational/it/schema/IoTDBTableIT.java | 80 +-
.../it/session/IoTDBSessionRelationalIT.java | 14 +-
.../org/apache/iotdb/db/qp/sql/IoTDBSqlParser.g4 | 2 +
.../antlr4/org/apache/iotdb/db/qp/sql/SqlLexer.g4 | 4 +
.../client/async/CnToDnAsyncRequestType.java | 1 +
.../CnToDnInternalServiceAsyncRequestManager.java | 6 +
.../rpc/DataNodeAsyncRequestRPCHandler.java | 1 +
.../consensus/request/ConfigPhysicalPlan.java | 8 +
.../consensus/request/ConfigPhysicalPlanType.java | 3 +
.../request/ConfigPhysicalPlanVisitor.java | 16 +
.../pipe/payload/PipeAlterTimeSeriesPlan.java | 110 +
.../AlterColumnDataTypePlan.java} | 39 +-
.../consensus/response/table/DescTableResp.java | 21 +-
.../iotdb/confignode/manager/ConfigManager.java | 32 +-
.../apache/iotdb/confignode/manager/IManager.java | 4 +
.../iotdb/confignode/manager/ProcedureManager.java | 37 +
.../receiver/protocol/IoTDBConfigNodeReceiver.java | 35 +
.../PipeConfigPhysicalPlanTSStatusVisitor.java | 18 +
.../pipe/source/ConfigRegionListeningFilter.java | 8 +-
.../source/PipeConfigTablePatternParseVisitor.java | 7 +
.../PipeConfigTablePrivilegeParseVisitor.java | 6 +
.../source/PipeConfigTreePatternParseVisitor.java | 21 +
.../PipeConfigTreePrivilegeParseVisitor.java | 37 +
.../manager/schema/ClusterSchemaManager.java | 43 +-
.../persistence/executor/ConfigPlanExecutor.java | 5 +
.../persistence/schema/ClusterSchemaInfo.java | 68 +-
.../confignode/persistence/schema/ConfigMTree.java | 78 +-
.../schema/mnode/impl/ConfigTableNode.java | 15 +
.../schema/mnode/info/ConfigTableInfo.java | 16 +
.../schema/AlterTimeSeriesDataTypeProcedure.java | 415 +++
.../table/AlterTableColumnDataTypeProcedure.java | 212 ++
.../schema/table/DropTableColumnProcedure.java | 2 +-
...ate.java => AlterTableColumnDataTypeState.java} | 6 +-
...tate.java => AlterTimeSeriesDataTypeState.java} | 8 +-
.../procedure/store/ProcedureFactory.java | 18 +
.../confignode/procedure/store/ProcedureType.java | 5 +
.../thrift/ConfigNodeRPCServiceProcessor.java | 6 +
.../request/ConfigPhysicalPlanSerDeTest.java | 33 +
.../PipeConfigTablePatternParseVisitorTest.java | 10 +
.../PipeConfigTreePatternParseVisitorTest.java | 21 +
.../schemaregion/SchemaExecutionVisitor.java | 14 +
...ion.java => DataTypeInconsistentException.java} | 9 +-
.../transform/converter/ValueConverter.java | 6 +-
.../visitor/PipePlanToStatementVisitor.java | 1 +
.../iotdb/db/protocol/client/ConfigNodeClient.java | 7 +
.../impl/DataNodeInternalRPCServiceImpl.java | 30 +
.../execution/aggregation/ExtremeAccumulator.java | 16 +-
.../aggregation/FirstValueAccumulator.java | 31 +-
.../aggregation/LastValueAccumulator.java | 31 +-
.../execution/aggregation/MaxValueAccumulator.java | 8 +-
.../execution/aggregation/MinValueAccumulator.java | 8 +-
.../execution/exchange/SharedTsBlockQueue.java | 4 +
.../exchange/source/LocalSourceHandle.java | 5 +
.../execution/executor/RegionWriteExecutor.java | 11 +
.../execution/operator/process/TopKOperator.java | 12 +-
.../execution/operator/source/FileLoaderUtils.java | 66 +-
.../execution/operator/source/SeriesScanUtil.java | 588 ++++-
.../relational/aggregation/ExtremeAccumulator.java | 16 +-
.../relational/aggregation/FirstAccumulator.java | 32 +-
.../relational/aggregation/FirstByAccumulator.java | 18 +-
.../relational/aggregation/LastAccumulator.java | 32 +-
.../relational/aggregation/LastByAccumulator.java | 8 +-
.../relational/aggregation/MaxAccumulator.java | 22 +-
.../relational/aggregation/MinAccumulator.java | 22 +-
.../iotdb/db/queryengine/plan/Coordinator.java | 2 +
.../execution/config/TableConfigTaskVisitor.java | 24 +-
.../execution/config/TreeConfigTaskVisitor.java | 8 +
.../config/executor/ClusterConfigTaskExecutor.java | 112 +-
.../config/executor/IConfigTaskExecutor.java | 15 +
...ompressorTask.java => AlterTimeSeriesTask.java} | 28 +-
...olumnTask.java => AlterColumnDataTypeTask.java} | 31 +-
.../relational/DescribeTableDetailsTask.java | 14 +-
.../db/queryengine/plan/parser/ASTVisitor.java | 39 +-
.../plan/planner/LogicalPlanVisitor.java | 19 +-
.../plan/planner/TableOperatorGenerator.java | 6 +-
.../plan/planner/plan/node/PlanVisitor.java | 4 +
.../node/metadata/write/AlterTimeSeriesNode.java | 87 +-
.../plan/node/pipe/PipeEnrichedInsertNode.java | 7 +
.../plan/node/write/InsertMultiTabletsNode.java | 9 +
.../plan/planner/plan/node/write/InsertNode.java | 5 +
.../planner/plan/node/write/InsertRowNode.java | 15 +
.../planner/plan/node/write/InsertRowsNode.java | 9 +
.../plan/node/write/InsertRowsOfOneDeviceNode.java | 9 +
.../planner/plan/node/write/InsertTabletNode.java | 11 +
.../plan/node/write/RelationalInsertRowNode.java | 11 +
.../plan/node/write/RelationalInsertRowsNode.java | 9 +
.../node/write/RelationalInsertTabletNode.java | 22 +
.../fetcher/TableHeaderSchemaValidator.java | 13 +-
.../security/TreeAccessCheckVisitor.java | 17 +
...tTableComment.java => AlterColumnDataType.java} | 124 +-
.../plan/relational/sql/ast/AstVisitor.java | 4 +
.../plan/relational/sql/parser/AstBuilder.java | 20 +
.../plan/statement/StatementVisitor.java | 6 +
....java => AlterTimeSeriesDataTypeStatement.java} | 19 +-
.../metadata/AlterTimeSeriesStatement.java | 15 +-
.../transformation/dag/util/TypeUtils.java | 3 +-
.../schemaengine/schemaregion/ISchemaRegion.java | 10 +
.../schemaregion/impl/SchemaRegionMemoryImpl.java | 16 +
.../schemaregion/impl/SchemaRegionPBTreeImpl.java | 15 +
.../mtree/impl/mem/MTreeBelowSGMemoryImpl.java | 45 +
.../mtree/impl/mem/mnode/info/LogicalViewInfo.java | 3 +
.../mtree/impl/mem/mnode/info/MeasurementInfo.java | 3 +
.../schemaregion/utils/ResourceByPathUtils.java | 21 +-
.../db/storageengine/dataregion/DataRegion.java | 159 +-
.../performer/impl/FastCompactionPerformer.java | 24 +-
.../impl/ReadChunkCompactionPerformer.java | 7 +-
.../subtask/FastCompactionPerformerSubTask.java | 33 +-
.../execute/utils/CompactionSeriesContext.java | 60 +
.../execute/utils/MultiTsFileDeviceIterator.java | 73 +-
.../fast/FastAlignedSeriesCompactionExecutor.java | 28 +-
.../FastNonAlignedSeriesCompactionExecutor.java | 36 +-
.../ReadChunkAlignedSeriesCompactionExecutor.java | 30 +-
.../readchunk/SingleSeriesCompactionExecutor.java | 12 +-
.../dataregion/memtable/AbstractMemTable.java | 12 +-
.../memtable/AlignedWritableMemChunk.java | 23 +-
.../memtable/AlignedWritableMemChunkGroup.java | 7 +
.../dataregion/memtable/IMemTable.java | 4 +
.../memtable/IWritableMemChunkGroup.java | 4 +
.../dataregion/memtable/ReadOnlyMemChunk.java | 8 +-
.../dataregion/memtable/TsFileProcessor.java | 4 +
.../dataregion/memtable/WritableMemChunkGroup.java | 18 +
.../read/reader/chunk/MemAlignedPageReader.java | 9 +-
.../org/apache/iotdb/db/utils/CommonUtils.java | 19 +
.../org/apache/iotdb/db/utils/SchemaUtils.java | 266 ++
.../db/utils/datastructure/AlignedTVList.java | 148 +-
.../db/utils/datastructure/BackIntTVList.java | 7 +
.../iotdb/db/utils/datastructure/IntTVList.java | 35 +-
.../db/utils/datastructure/QuickIntTVList.java | 7 +
.../iotdb/db/utils/datastructure/TVList.java | 11 +-
.../iotdb/db/utils/datastructure/TimIntTVList.java | 7 +
...hTest.java => CompactionDataTypeAlterTest.java} | 136 +-
...tionDataTypeNotMatchAlterableDataTypeTest.java} | 33 +-
.../FastNonAlignedCrossCompactionTest.java | 5 +
.../ReadPointNonAlignedCrossCompactionTest.java | 4 +
.../org/apache/iotdb/db/utils/SchemaUtilsTest.java | 39 +
.../db/utils/datastructure/AlignedTVListTest.java | 10 +-
.../db/utils/datastructure/IntTVListTest.java | 11 +-
.../apache/iotdb/commons/path/MeasurementPath.java | 31 +
.../table/AlterOrDropTableOperationType.java | 5 +-
.../apache/iotdb/commons/schema/table/TsTable.java | 46 +-
.../schema/table/column/AttributeColumnSchema.java | 7 +
.../schema/table/column/FieldColumnSchema.java | 14 +-
.../schema/table/column/TagColumnSchema.java | 6 +
.../schema/table/column/TimeColumnSchema.java | 6 +
.../schema/table/column/TsTableColumnSchema.java | 6 +
.../table/column/TsTableColumnSchemaUtil.java | 12 +
.../tree/AlterTimeSeriesOperationType.java} | 22 +-
.../apache/iotdb/commons/utils/MetadataUtils.java} | 13 +-
.../apache/iotdb/commons/utils/WindowsOSUtils.java | 64 +
...ommonUtilsTest.java => WindowsOSUtilsTest.java} | 25 +-
.../db/relational/grammar/sql/RelationalSql.g4 | 1 +
.../src/main/thrift/confignode.thrift | 14 +
.../src/main/thrift/datanode.thrift | 14 +-
pom.xml | 2 +-
161 files changed, 9554 insertions(+), 457 deletions(-)
create mode 100644
integration-test/src/test/java/org/apache/iotdb/db/it/schema/IoTDBAlterTimeSeriesTypeIT.java
create mode 100644
integration-test/src/test/java/org/apache/iotdb/relational/it/schema/IoTDBAlterColumnTypeIT.java
create mode 100644
iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/consensus/request/write/pipe/payload/PipeAlterTimeSeriesPlan.java
copy
iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/consensus/request/write/{template/DropSchemaTemplatePlan.java
=> table/AlterColumnDataTypePlan.java} (58%)
create mode 100644
iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/procedure/impl/schema/AlterTimeSeriesDataTypeProcedure.java
create mode 100644
iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/procedure/impl/schema/table/AlterTableColumnDataTypeProcedure.java
copy
iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/procedure/state/schema/{AddTableColumnState.java
=> AlterTableColumnDataTypeState.java} (89%)
copy
iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/procedure/state/schema/{DeleteDatabaseState.java
=> AlterTimeSeriesDataTypeState.java} (88%)
copy
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/exception/{BadNodeUrlFormatException.java
=> DataTypeInconsistentException.java} (74%)
copy
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/execution/config/metadata/{AlterEncodingCompressorTask.java
=> AlterTimeSeriesTask.java} (60%)
copy
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/execution/config/metadata/relational/{AlterTableDropColumnTask.java
=> AlterColumnDataTypeTask.java} (65%)
copy
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/relational/sql/ast/{SetTableComment.java
=> AlterColumnDataType.java} (51%)
copy
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/statement/metadata/{ShowVariablesStatement.java
=> AlterTimeSeriesDataTypeStatement.java} (78%)
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/storageengine/dataregion/compaction/execute/utils/CompactionSeriesContext.java
copy
iotdb-core/datanode/src/test/java/org/apache/iotdb/db/storageengine/dataregion/compaction/{CompactionDataTypeNotMatchTest.java
=> CompactionDataTypeAlterTest.java} (58%)
copy
iotdb-core/datanode/src/test/java/org/apache/iotdb/db/storageengine/dataregion/compaction/{CompactionDataTypeNotMatchTest.java
=> CompactionDataTypeNotMatchAlterableDataTypeTest.java} (91%)
copy
iotdb-core/node-commons/src/main/java/org/apache/iotdb/commons/{cq/CQState.java
=> schema/tree/AlterTimeSeriesOperationType.java} (71%)
copy
iotdb-core/{datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/relational/utils/ConversionUtils.java
=>
node-commons/src/main/java/org/apache/iotdb/commons/utils/MetadataUtils.java}
(77%)
create mode 100644
iotdb-core/node-commons/src/main/java/org/apache/iotdb/commons/utils/WindowsOSUtils.java
copy
iotdb-core/node-commons/src/test/java/org/apache/iotdb/commons/utils/{JVMCommonUtilsTest.java
=> WindowsOSUtilsTest.java} (60%)
