This is an automated email from the ASF dual-hosted git repository. rong pushed a commit to branch tsfile-tablet-converter in repository https://gitbox.apache.org/repos/asf/iotdb.git
commit 2ac31c65e14c1569493a7cf55f01e030861e2ebe Merge: cee7d7af04e cd8a4610fb3 Author: Steve Yurong Su <[email protected]> AuthorDate: Mon Aug 19 17:59:32 2024 +0800 Merge branch 'master' of https://github.com/apache/iotdb into tsfile-tablet-converter .github/workflows/cluster-it-1c3d.yml | 2 +- .github/workflows/{unit-test.yml => daily-ut.yml} | 30 +- .github/workflows/multi-language-client.yml | 15 +- .github/workflows/pipe-it-2cluster.yml | 49 +- ...uster-it-1c3d.yml => table-cluster-it-1c1d.yml} | 44 +- ...uster-it-1c3d.yml => table-cluster-it-1c3d.yml} | 8 +- .github/workflows/unit-test.yml | 9 +- example/pipe-count-point-processor/pom.xml | 2 +- integration-test/README.md | 24 +- integration-test/pom.xml | 48 +- .../java/org/apache/iotdb/it/env/EnvFactory.java | 2 + .../main/java/org/apache/iotdb/it/env/EnvType.java | 3 +- .../iotdb/it/env/cluster/env/AbstractEnv.java | 5 +- ...ltiClusterIT2SubscriptionArchVerification.java} | 2 +- ... => MultiClusterIT2SubscriptionRegression.java} | 2 +- ...terIT2Subscription.java => TableClusterIT.java} | 2 +- ...bscription.java => TableLocalStandaloneIT.java} | 2 +- .../org/apache/iotdb/db/it/IoTDBRestartIT.java | 54 +- .../iotdb/db/it/selectinto/IoTDBSelectIntoIT.java | 21 + .../org/apache/iotdb/db/it/utils/TestUtils.java | 23 + .../it/db/it/IoTDBExecuteBatchTableIT.java | 7 +- .../it/db/it/IoTDBFlushQueryTableIT.java | 6 +- .../it/db/it/IoTDBInsertAlignedValuesTableIT.java | 6 +- .../relational/it/db/it/IoTDBInsertTableIT.java | 139 +- .../it/db/it/IoTDBMultiDeviceTableIT.java | 6 +- .../relational/it/db/it/IoTDBRecoverTableIT.java | 6 +- .../it/db/it/IoTDBRecoverUnclosedTableIT.java | 6 +- .../relational/it/db/it/IoTDBRestartTableIT.java | 90 +- .../it/db/it/IoTDBSetConfigurationTableIT.java | 4 +- .../it/query/old/IoTDBDatetimeFormatTableIT.java | 6 +- .../it/query/old/IoTDBFilterBetweenTableIT.java | 6 +- .../it/query/old/IoTDBFilterNullTableIT.java | 6 +- .../it/query/old/IoTDBFilterTableIT.java | 5 +- .../it/query/old/IoTDBNestedQueryTableIT.java | 6 +- .../it/query/old/IoTDBSimpleQueryTableIT.java | 6 +- .../alignbydevice/IoTDBAlignByDeviceTable2IT.java | 6 +- .../alignbydevice/IoTDBAlignByDeviceTable3IT.java | 6 +- .../alignbydevice/IoTDBAlignByDeviceTableIT.java | 6 +- .../IoTDBAlignByDeviceWithTemplateTable2IT.java | 6 +- .../IoTDBAlignByDeviceWithTemplateTableIT.java | 6 +- ...TDBOrderByLimitOffsetAlignByDeviceTable2IT.java | 6 +- ...oTDBOrderByLimitOffsetAlignByDeviceTableIT.java | 6 +- .../IoTDBOrderByWithAlignByDeviceTable2IT.java | 6 +- .../IoTDBOrderByWithAlignByDeviceTable3IT.java | 6 +- .../IoTDBOrderByWithAlignByDeviceTableIT.java | 6 +- .../IoTDBAlignedOffsetLimitPushDownTableIT.java | 6 +- .../aligned/IoTDBAlignedSeriesQueryTable2IT.java | 6 +- .../aligned/IoTDBAlignedSeriesQueryTable3IT.java | 6 +- .../aligned/IoTDBAlignedSeriesQueryTable4IT.java | 6 +- .../aligned/IoTDBAlignedSeriesQueryTable5IT.java | 6 +- .../aligned/IoTDBAlignedSeriesQueryTableIT.java | 6 +- .../aligned/IoTDBPredicatePushDownTable2IT.java | 6 +- .../aligned/IoTDBPredicatePushDownTable3IT.java | 6 +- .../aligned/IoTDBPredicatePushDownTable4IT.java | 6 +- .../old/aligned/IoTDBPredicatePushDownTableIT.java | 6 +- .../scalar/IoTDBCastFunctionTableIT.java | 6 +- .../scalar/IoTDBDiffFunctionTable2IT.java | 6 +- .../scalar/IoTDBDiffFunctionTable3IT.java | 6 +- .../scalar/IoTDBDiffFunctionTableIT.java | 6 +- .../scalar/IoTDBReplaceFunctionTableIT.java | 6 +- .../scalar/IoTDBRoundFunctionTableIT.java | 6 +- .../scalar/IoTDBScalarFunctionTableIT.java | 2691 ++++++++++++++++++++ .../scalar/IoTDBSubStringFunctionTableIT.java | 6 +- ...ava => IoTDBMultiIDsWithAttributesTableIT.java} | 116 +- .../it/query/old/orderBy/IoTDBOrderByTableIT.java | 6 +- .../it/query/old/query/IoTDBArithmeticTableIT.java | 6 +- .../query/old/query/IoTDBCaseWhenThenTableIT.java | 6 +- .../it/query/old/query/IoTDBFuzzyQueryTableIT.java | 6 +- .../it/query/old/query/IoTDBInTableIT.java | 6 +- ...oTDBNoSelectExpressionAfterAnalyzedTableIT.java | 6 +- .../query/old/query/IoTDBNullOperandTableIT.java | 6 +- .../query/old/query/IoTDBNullValueFillTableIT.java | 6 +- .../it/query/old/query/IoTDBPaginationTableIT.java | 6 +- .../it/query/old/query/IoTDBQueryDemoTableIT.java | 6 +- .../IoTDBQueryWithComplexValueFilterTableIT.java | 6 +- .../it/query/old/query/IoTDBResultSetTableIT.java | 6 +- .../query/IoTDBSelectCompareExpressionTableIT.java | 6 +- .../query/old/query/IoTDBSelectSchemaTableIT.java | 6 +- .../it/query/recent/IoTDBNullIdQueryIT.java | 30 +- .../relational/it/schema/IoTDBDatabaseIT.java | 6 +- .../relational/it/schema/IoTDBDeviceQueryIT.java | 71 +- .../iotdb/relational/it/schema/IoTDBTableIT.java | 74 +- .../it/session/IoTDBTableModelSessionIT.java | 6 +- .../session/pool/IoTDBTableModelSessionPoolIT.java | 6 +- .../subscription/it/AbstractSubscriptionIT.java | 13 +- .../apache/iotdb/subscription/it/DisplayName.java} | 25 +- .../it/SkipOnSetUpAndTearDownFailure.java | 114 + .../iotdb/subscription/it/SkipOnSetUpFailure.java | 82 - .../it/cluster/IoTDBSubscriptionRestartIT.java | 98 +- .../it/dual/AbstractSubscriptionDualIT.java | 10 +- .../it/dual/IoTDBSubscriptionConsumerGroupIT.java | 10 +- .../it/dual/IoTDBSubscriptionTimePrecisionIT.java | 6 +- .../it/dual/IoTDBSubscriptionTopicIT.java | 18 +- .../it/local/AbstractSubscriptionLocalIT.java | 10 +- .../it/local/IoTDBSubscriptionBasicIT.java | 4 +- .../it/local/IoTDBSubscriptionDataTypeIT.java | 2 +- .../it/triple/AbstractSubscriptionTripleIT.java | 10 +- .../it/triple/IoTDBSubscriptionSharingIT.java | 18 +- .../AbstractSubscriptionRegressionIT.java | 467 ++++ .../IoTDBDefaultPullConsumerDataSetIT.java | 142 ++ .../IoTDBDefaultTsfilePushConsumerIT.java | 224 ++ .../IoTDBRootDatasetPushConsumerIT.java | 186 ++ .../IoTDBRootPullConsumeTsfileIT.java | 147 ++ ...merPullConsumerWith1TopicShareProcessMixIT.java | 196 ++ ...DBTestAutoCommitFalseDataSetPullConsumerIT.java | 191 ++ ...TDBTestAutoCommitTrueDataSetPullConsumerIT.java | 175 ++ .../format/IoTDBDBDataSetPullConsumerIT.java | 154 ++ .../format/IoTDBDBTsfilePullConsumerIT.java | 155 ++ .../IoTDBAllTsDatasetPullConsumerIT.java | 208 ++ .../IoTDBAllTsTsfilePullConsumerIT.java | 199 ++ .../IoTDBAllTsfilePullConsumerSnapshotIT.java | 201 ++ .../IoTDBPathDeviceDataSetPullConsumerIT.java | 170 ++ .../IoTDBPathDeviceTsfilePullConsumerIT.java | 189 ++ .../IoTDBTimeTsDatasetPullConsumerIT.java | 212 ++ .../IoTDBTimeTsTsfilePullConsumerIT.java | 203 ++ .../IoTDBSnapshotDevicePullConsumerDataSetIT.java | 152 ++ .../IoTDBSnapshotDevicePullConsumerTsfileIT.java | 182 ++ ...DBConsumer2With1TopicShareProcessDataSetIT.java | 145 ++ ...TDBConsumer2With1TopicShareProcessTsfileIT.java | 198 ++ .../multi/IoTDBMultiGroupVsMultiConsumerIT.java | 215 ++ .../IoTDBOneConsumerMultiTopicsDatasetIT.java | 183 ++ .../multi/IoTDBOneConsumerMultiTopicsMixIT.java | 319 +++ .../multi/IoTDBOneConsumerMultiTopicsTsfileIT.java | 211 ++ .../pattern/IoTDBDBPatternPullConsumeTsfileIT.java | 177 ++ .../IoTDBDBPatternPullConsumerDataSetIT.java | 150 ++ .../IoTDBDefaultPatternPullConsumerDataSetIT.java | 145 ++ .../IoTDBDevicePatternPullConsumeTsfileIT.java | 176 ++ .../IoTDBDevicePatternPullConsumerDataSetIT.java | 156 ++ ...DBMiddleMatch2PatternPullConsumerDataSetIT.java | 174 ++ ...IoTDBMiddleMatchPatternPullConsumeTsfileIT.java | 177 ++ ...TDBMiddleMatchPatternPullConsumerDataSetIT.java | 184 ++ .../IoTDBRootPatternPullConsumeTsfileIT.java | 152 ++ .../pattern/IoTDBTSPatternPullConsumeTsfileIT.java | 182 ++ .../IoTDBTSPatternPullConsumerDataSetIT.java | 132 + .../time/IoTDBAllPullConsumerDataSetIT.java | 131 + .../time/IoTDBHistoryPullConsumerDataSetIT.java | 139 + .../time/IoTDBRealTimePullConsumerDataSetIT.java | 138 + ...oTDBTimeRangeAccuratePullConsumerDataSetIT.java | 136 + .../time/IoTDBTimeRangePullConsumerDataSetIT.java | 140 + .../format/IoTDBTestPushConsumeDataSetIT.java | 179 ++ .../IoTDBTestPushConsumeNoTargetDirTsfileIT.java | 181 ++ .../format/IoTDBTestPushConsumeTsfileIT.java | 181 ++ .../IoTDBLooseAllTsDatasetPushConsumerIT.java | 228 ++ ...TDBLooseAllTsDatasetPushConsumerSnapshotIT.java | 227 ++ .../IoTDBLooseAllTsfilePushConsumerIT.java | 257 ++ .../IoTDBPathLooseDeviceTsfilePushConsumerIT.java | 254 ++ .../IoTDBPathLooseTsDatasetPushConsumerIT.java | 255 ++ .../IoTDBPathLooseTsfilePushConsumerIT.java | 224 ++ .../IoTDBPathTsLooseDatasetPushConsumerIT.java | 209 ++ .../IoTDBTimeLooseTsDatasetPushConsumerIT.java | 220 ++ .../IoTDBTimeLooseTsTsfilePushConsumerIT.java | 277 ++ .../IoTDBTimeLooseTsfilePushConsumerIT.java | 237 ++ .../IoTDBTimeTsLooseDatasetPushConsumerIT.java | 219 ++ ...oTDBSnapshotTSPatternDatasetPushConsumerIT.java | 196 ++ ...IoTDBSnapshotTSPatternTsfilePushConsumerIT.java | 246 ++ ...DBConsumer2With1TopicShareProcessDataSetIT.java | 216 ++ ...TDBConsumer2With1TopicShareProcessTsfileIT.java | 223 ++ .../multi/IoTDBMultiGroupVsMultiConsumerIT.java | 604 +++++ .../IoTDBOneConsumerMultiTopicsDatasetIT.java | 202 ++ .../multi/IoTDBOneConsumerMultiTopicsMixIT.java | 239 ++ .../multi/IoTDBOneConsumerMultiTopicsTsfileIT.java | 211 ++ .../IoTDBDBPatternDatasetPushConsumerIT.java | 191 ++ .../IoTDBDBPatternTsfilePushConsumerIT.java | 221 ++ .../IoTDBDefaultPatternTsfilePushConsumerIT.java | 220 ++ .../IoTDBDevicePatternDatasetPushConsumerIT.java | 190 ++ .../IoTDBDevicePatternTsfilePushConsumerIT.java | 233 ++ .../IoTDBRootPatternDatasetPushConsumerIT.java | 191 ++ .../IoTDBTSPatternDatasetPushConsumerIT.java | 190 ++ .../IoTDBTSPatternTsfilePushConsumerIT.java | 227 ++ .../IoTDBHistoryRootDatasetPushConsumerIT.java | 175 ++ .../time/IoTDBHistoryRootTsFilePushConsumerIT.java | 178 ++ .../time/IoTDBRealTimeDBDatasetPushConsumerIT.java | 164 ++ .../time/IoTDBRealTimeDBTsfilePushConsumerIT.java | 180 ++ ...DBTimeRangeAccurateDBDataSetPushConsumerIT.java | 180 ++ .../IoTDBTimeRangeDBDataSetPushConsumerIT.java | 181 ++ .../time/IoTDBTimeRangeDBTsfilePushConsumerIT.java | 199 ++ .../topic/IoTDBDataSet1TopicConsumerSpecialIT.java | 142 ++ .../regression/topic/IoTDBTestTopicNameIT.java | 139 + .../src/main/java/org/apache/iotdb/cli/Cli.java | 5 + .../org/apache/iotdb/cli/utils/JlineUtils.java | 4 + .../java/org/apache/iotdb/rpc/TSStatusCode.java | 1 + .../consensus/request/ConfigPhysicalPlan.java | 4 + .../consensus/request/ConfigPhysicalPlanType.java | 1 + .../write/table/SetTablePropertiesPlan.java | 79 + .../iotdb/confignode/manager/ConfigManager.java | 2 + .../iotdb/confignode/manager/ProcedureManager.java | 282 +- .../manager/load/cache/AbstractLoadCache.java | 2 +- .../manager/schema/ClusterSchemaManager.java | 91 +- .../persistence/executor/ConfigPlanExecutor.java | 3 + .../persistence/schema/ClusterSchemaInfo.java | 30 +- .../confignode/persistence/schema/ConfigMTree.java | 71 +- .../impl/region/RegionMigrateProcedure.java | 5 +- .../procedure/impl/schema/SchemaUtils.java | 70 + .../impl/schema/table/AddTableColumnProcedure.java | 145 +- .../impl/schema/table/CreateTableProcedure.java | 130 +- .../schema/table/SetTablePropertiesProcedure.java | 325 +++ .../state/schema/SetTablePropertiesState.java | 9 +- .../procedure/store/ProcedureFactory.java | 15 +- .../confignode/procedure/store/ProcedureType.java | 1 + .../request/ConfigPhysicalPlanSerDeTest.java | 16 + .../table/SetTablePropertiesProcedureTest.java | 63 + .../org/apache/iotdb/consensus/IStateMachine.java | 2 +- .../consensus/iot/IoTConsensusServerImpl.java | 5 +- .../service/IoTConsensusRPCServiceProcessor.java | 3 +- .../dataregion/DataRegionStateMachine.java | 11 +- .../table/TableAlreadyExistsException.java | 2 +- .../metadata/table/TableNotExistsException.java | 2 +- .../db/pipe/agent/task/PipeDataNodeTaskAgent.java | 15 + .../request/PipeTransferTabletRawReq.java | 1 + ...aNodeHardlinkOrCopiedFileDirStartupCleaner.java | 21 +- .../v1/handler/StatementConstructionHandler.java | 1 + .../v2/handler/StatementConstructionHandler.java | 2 + .../protocol/thrift/impl/ClientRPCServiceImpl.java | 13 +- .../operator/schema/SchemaCountOperator.java | 4 +- .../schema/source/DevicePredicateFilter.java | 51 + .../schema/source/SchemaSourceFactory.java | 21 +- .../schema/source/TableDeviceQuerySource.java | 77 +- .../relational/ColumnTransformerBuilder.java | 323 ++- .../iotdb/db/queryengine/plan/Coordinator.java | 4 + .../queryengine/plan/analyze/AnalyzeVisitor.java | 17 +- .../plan/analyze/schema/SchemaValidator.java | 1 + .../execution/config/TableConfigTaskVisitor.java | 119 +- .../config/executor/ClusterConfigTaskExecutor.java | 69 +- .../config/executor/IConfigTaskExecutor.java | 31 +- .../relational/AlterTableAddColumnTask.java | 70 +- ...eTask.java => AlterTableSetPropertiesTask.java} | 31 +- .../metadata/relational/CreateTableTask.java | 4 +- .../TableModelStatementMemorySourceVisitor.java | 32 +- .../plan/planner/TableOperatorGenerator.java | 50 +- .../node/metadata/read/TableDeviceFetchNode.java | 6 - .../metadata/read/TableDeviceQueryCountNode.java | 8 + .../planner/plan/node/write/InsertRowsNode.java | 4 + .../plan/node/write/RelationalInsertRowsNode.java | 4 + .../relational/analyzer/StatementAnalyzer.java | 122 +- .../schema/CheckSchemaPredicateVisitor.java | 24 +- .../schema/ExtractPredicateColumnNameVisitor.java | 11 +- .../plan/relational/metadata/MetadataUtil.java | 8 +- .../relational/metadata/TableMetadataImpl.java | 285 ++- .../metadata/fetcher/SchemaPredicateUtil.java | 5 +- .../metadata/fetcher/TableDeviceSchemaFetcher.java | 103 +- .../fetcher/TableHeaderSchemaValidator.java | 96 +- .../plan/relational/planner/LogicalPlanner.java | 69 +- .../plan/relational/planner/PlanBuilder.java | 24 +- .../plan/relational/planner/QueryPlanner.java | 57 +- .../plan/relational/planner/RelationPlanner.java | 22 +- .../plan/relational/planner/SubqueryPlanner.java | 322 +++ .../plan/relational/planner/TranslationMap.java | 19 + .../distribute/TableModelQueryFragmentPlanner.java | 5 +- .../TableModelTypeProviderExtractor.java | 24 + .../relational/planner/ir/ExpressionRewriter.java | 14 +- .../planner/ir/ExpressionTreeRewriter.java | 31 + .../plan/relational/planner/ir/IrVisitor.java | 5 + .../relational/planner/ir/RewritingVisitor.java | 19 + .../relational/planner/node/TableScanNode.java | 4 - .../optimizations/PushPredicateIntoTableScan.java | 44 +- .../sql/ast/AbstractQueryDeviceWithCache.java | 103 + ...ueryDevice.java => AbstractTraverseDevice.java} | 75 +- .../plan/relational/sql/ast/AddColumn.java | 59 +- .../plan/relational/sql/ast/ColumnDefinition.java | 30 +- .../plan/relational/sql/ast/CountDevice.java | 30 +- .../plan/relational/sql/ast/CreateTable.java | 28 +- .../sql/ast/DefaultTraversalVisitor.java | 10 +- .../plan/relational/sql/ast/InsertRow.java | 10 +- .../plan/relational/sql/ast/InsertRows.java | 20 +- .../plan/relational/sql/ast/InsertTablet.java | 9 +- .../plan/relational/sql/ast/SetProperties.java | 29 +- .../plan/relational/sql/ast/ShowDevice.java | 41 +- .../relational/sql/ast/WrappedInsertStatement.java | 4 + .../plan/relational/sql/parser/AstBuilder.java | 47 +- .../plan/relational/sql/util/SqlFormatter.java | 24 +- .../plan/statement/crud/InsertBaseStatement.java | 24 + .../crud/InsertMultiTabletsStatement.java | 28 + .../crud/InsertRowsOfOneDeviceStatement.java | 28 + .../plan/statement/crud/InsertRowsStatement.java | 28 + .../column/unary/scalar/AbsColumnTransformer.java | 56 + .../column/unary/scalar/AcosColumnTransformer.java | 54 + .../column/unary/scalar/AsinColumnTransformer.java | 54 + .../column/unary/scalar/AtanColumnTransformer.java | 54 + .../column/unary/scalar/CeilColumnTransformer.java | 54 + .../unary/scalar/Concat2ColumnTransformer.java | 61 + .../unary/scalar/ConcatColumnTransformer.java | 66 + .../unary/scalar/ConcatMultiColumnTransformer.java | 74 + .../column/unary/scalar/CosColumnTransformer.java | 54 + .../column/unary/scalar/CoshColumnTransformer.java | 54 + .../unary/scalar/DegreesColumnTransformer.java | 54 + .../unary/scalar/EndsWith2ColumnTransformer.java | 56 + .../unary/scalar/EndsWithColumnTransformer.java | 52 + .../column/unary/scalar/ExpColumnTransformer.java | 54 + .../unary/scalar/FloorColumnTransformer.java | 54 + .../unary/scalar/LTrim2ColumnTransformer.java | 56 + .../unary/scalar/LTrimColumnTransformer.java | 70 + .../unary/scalar/LengthColumnTransformer.java | 47 + .../column/unary/scalar/LnColumnTransformer.java | 54 + .../unary/scalar/Log10ColumnTransformer.java | 54 + .../unary/scalar/LowerColumnTransformer.java | 47 + .../unary/scalar/RTrim2ColumnTransformer.java | 56 + .../unary/scalar/RTrimColumnTransformer.java | 70 + .../unary/scalar/RadiansColumnTransformer.java | 54 + .../unary/scalar/RegexpLike2ColumnTransformer.java | 54 + .../unary/scalar/RegexpLikeColumnTransformer.java | 52 + .../column/unary/scalar/SignColumnTransformer.java | 54 + .../column/unary/scalar/SinColumnTransformer.java | 54 + .../column/unary/scalar/SinhColumnTransformer.java | 54 + .../column/unary/scalar/SqrtColumnTransformer.java | 54 + .../unary/scalar/StartsWith2ColumnTransformer.java | 55 + .../unary/scalar/StartsWithColumnTransformer.java | 61 + .../unary/scalar/Strcmp2ColumnTransformer.java | 54 + .../unary/scalar/StrcmpColumnTransformer.java | 50 + .../unary/scalar/Strpos2ColumnTransformer.java | 54 + .../unary/scalar/StrposColumnTransformer.java | 50 + .../unary/scalar/TableBuiltinScalarFunction.java | 70 + .../column/unary/scalar/TanColumnTransformer.java | 54 + .../column/unary/scalar/TanhColumnTransformer.java | 54 + .../unary/scalar/Trim2ColumnTransformer.java | 56 + .../column/unary/scalar/TrimColumnTransformer.java | 82 + .../unary/scalar/UpperColumnTransformer.java | 48 + .../schemaengine/schemaregion/ISchemaRegion.java | 5 +- .../schemaregion/impl/SchemaRegionMemoryImpl.java | 9 +- .../schemaregion/impl/SchemaRegionPBTreeImpl.java | 5 +- .../mtree/impl/mem/MTreeBelowSGMemoryImpl.java | 31 +- .../read/resp/info/impl/ShowDevicesResult.java | 18 + .../java/org/apache/iotdb/db/service/DataNode.java | 59 +- .../db/storageengine/dataregion/DataRegion.java | 2 +- .../dataregion/memtable/AbstractMemTable.java | 47 + .../dataregion/snapshot/SnapshotTaker.java | 34 +- .../dataregion/wal/buffer/WALEntry.java | 3 + .../dataregion/wal/buffer/WALEntryType.java | 7 +- .../file/AbstractTsFileRecoverPerformer.java | 5 + .../file/UnsealedTsFileRecoverPerformer.java | 1 + .../iotdb/db/utils/constant/SqlConstant.java | 3 + .../schemaRegion/SchemaRegionTableDeviceTest.java | 74 +- .../schemaRegion/SchemaRegionTestUtil.java | 6 +- .../plan/relational/analyzer/AnalyzerTest.java | 16 +- .../plan/relational/analyzer/SortTest.java | 9 +- .../wal/recover/WALRecoverManagerTest.java | 82 + .../src/test/resources/oldwal/1723544967972-1-0-0 | Bin 0 -> 237 bytes .../datanode/src/test/resources/oldwal/_0-0-0.wal | Bin 0 -> 265150 bytes .../src/test/resources/oldwal/_0.checkpoint | Bin 0 -> 533 bytes .../datanode/src/test/resources/oldwal/_1-0-0.wal | Bin 0 -> 259747 bytes .../datanode/src/test/resources/oldwal/_2-0-0.wal | Bin 0 -> 36948 bytes .../datanode/src/test/resources/oldwal/_3-0-1.wal | Bin 0 -> 513 bytes .../AbstractSerializableListeningQueue.java | 4 +- .../iotdb/commons/pipe/task/PipeTaskManager.java | 13 + .../iotdb/commons/schema/SchemaConstant.java | 1 + .../schema/table/AlterTableOperationType.java | 9 +- .../apache/iotdb/commons/schema/table/TsTable.java | 20 +- .../db/relational/grammar/sql/RelationalSql.g4 | 13 +- pom.xml | 8 +- 348 files changed, 25861 insertions(+), 1607 deletions(-)
