This is an automated email from the ASF dual-hosted git repository. rong pushed a commit to branch pipe-parallel-connector in repository https://gitbox.apache.org/repos/asf/iotdb.git
commit 2308c5fbce75b40404917f6957b40806f787beaf Merge: 9e90f853bc7 68a8247ec35 Author: Steve Yurong Su <[email protected]> AuthorDate: Fri Jun 16 02:42:48 2023 +0800 Merge branch 'master' of github.com:apache/iotdb into pipe-parallel-connector .../antlr4/org/apache/iotdb/db/qp/sql/SqlLexer.g4 | 49 ++++ .../confignode/client/DataNodeRequestType.java | 2 + .../client/async/AsyncDataNodeClientPool.java | 29 ++- .../client/async/handlers/AsyncClientHandler.java | 5 +- ...RPCHandler.java => SchemaUpdateRPCHandler.java} | 6 +- .../iotdb/confignode/manager/ConfigManager.java | 11 + .../apache/iotdb/confignode/manager/IManager.java | 3 + .../iotdb/confignode/manager/ProcedureManager.java | 52 +++- .../persistence/executor/ConfigPlanExecutor.java | 15 +- ...ocedure.java => AlterLogicalViewProcedure.java} | 288 ++++++++++----------- .../impl/schema/DeleteLogicalViewProcedure.java | 3 +- .../state/schema/AlterLogicalViewState.java | 25 ++ .../procedure/store/ProcedureFactory.java | 6 + .../confignode/procedure/store/ProcedureType.java | 3 +- .../thrift/ConfigNodeRPCServiceProcessor.java | 6 + docs/Download/README.md | 22 +- docs/UserGuide/Reference/Common-Config-Manual.md | 10 +- .../Reference/ConfigNode-Config-Manual.md | 8 +- docs/UserGuide/Reference/DataNode-Config-Manual.md | 12 +- docs/zh/Download/README.md | 22 +- .../zh/UserGuide/Reference/Common-Config-Manual.md | 10 +- .../Reference/ConfigNode-Config-Manual.md | 8 +- .../UserGuide/Reference/DataNode-Config-Manual.md | 12 +- .../it/partition/IoTDBPartitionGetterIT.java | 2 +- .../db/it/aligned/IoTDBInsertAlignedValuesIT.java | 60 +++-- .../db/it/schema/view/IoTDBAliasSeriesIT.java | 13 +- .../iotdb/db/it/schema/view/IoTDBAlterViewIT.java | 117 +++++++++ .../iotdb/db/it/selectinto/IoTDBSelectIntoIT.java | 38 ++- iotdb-client/client-cpp/src/main/Session.h | 5 +- .../src/main/thrift/confignode.thrift | 7 + .../thrift/src/main/thrift/datanode.thrift | 7 + .../resources/conf/iotdb-common.properties | 2 +- .../org/apache/iotdb/commons/path/PartialPath.java | 10 + .../apache/iotdb/commons/path/PathPatternUtil.java | 4 + .../org/apache/iotdb/commons/utils/AuthUtils.java | 8 + .../apache/iotdb/db/client/ConfigNodeClient.java | 22 ++ .../java/org/apache/iotdb/db/conf/IoTDBConfig.java | 31 ++- .../org/apache/iotdb/db/conf/IoTDBDescriptor.java | 8 +- .../iotdb/db/conf/directories/TierManager.java | 7 +- .../CompactionFileCountExceededException.java | 26 ++ .../execute/task/AbstractCompactionTask.java | 6 +- .../execute/task/CrossSpaceCompactionTask.java | 30 ++- .../execute/task/InnerSpaceCompactionTask.java | 7 +- .../impl/RewriteCrossSpaceCompactionSelector.java | 2 +- .../impl/SizeTieredCompactionSelector.java | 2 +- .../db/engine/settle/SettleRequestHandler.java | 2 +- .../metadata/view/ViewNotExistException.java | 25 -- .../db/metadata/cache/TimeSeriesSchemaCache.java | 8 +- .../db/metadata/mtree/MTreeBelowSGCachedImpl.java | 4 +- .../db/metadata/mtree/MTreeBelowSGMemoryImpl.java | 4 +- .../plan/schemaregion/SchemaRegionPlanType.java | 1 + .../plan/schemaregion/SchemaRegionPlanVisitor.java | 5 + .../impl/SchemaRegionPlanDeserializer.java | 9 + .../impl/SchemaRegionPlanSerializer.java | 13 + .../impl/SchemaRegionPlanTxtSerializer.java | 11 + .../impl/write/AlterLogicalViewPlanImpl.java | 56 ++++ .../impl/write/SchemaRegionWritePlanFactory.java | 8 + .../write/view/IAlterLogicalViewPlan.java | 46 ++++ .../db/metadata/schemaregion/ISchemaRegion.java | 3 + .../schemaregion/SchemaRegionMemoryImpl.java | 23 ++ .../schemaregion/SchemaRegionSchemaFileImpl.java | 7 + .../metadata/visitor/SchemaExecutionVisitor.java | 20 ++ .../mpp/common/schematree/ClusterSchemaTree.java | 10 +- .../operator/source/ShowQueriesOperator.java | 6 +- .../iotdb/db/mpp/plan/analyze/AnalyzeVisitor.java | 1 + .../iotdb/db/mpp/plan/analyze/SelectIntoUtils.java | 9 +- .../mpp/plan/analyze/schema/ISchemaValidation.java | 6 + .../plan/analyze/schema/NormalSchemaFetcher.java | 66 ++++- .../config/executor/ClusterConfigTaskExecutor.java | 74 +++--- .../iotdb/db/mpp/plan/parser/ASTVisitor.java | 10 +- .../db/mpp/plan/planner/LogicalPlanVisitor.java | 22 +- .../plan/planner/distribution/SourceRewriter.java | 122 ++++++--- .../mpp/plan/planner/plan/node/PlanNodeType.java | 6 +- .../db/mpp/plan/planner/plan/node/PlanVisitor.java | 5 + .../metedata/write/view/AlterLogicalViewNode.java | 186 +++++++++++++ .../plan/statement/crud/InsertRowStatement.java | 11 +- .../plan/statement/crud/InsertTabletStatement.java | 11 +- .../metadata/view/AlterLogicalViewStatement.java | 11 - .../metadata/view/CreateLogicalViewStatement.java | 4 + .../org/apache/iotdb/db/rescon/SystemInfo.java | 54 ++++ .../iotdb/db/service/metrics/WritingMetrics.java | 20 ++ .../impl/DataNodeInternalRPCServiceImpl.java | 35 +++ .../iotdb/db/utils/TimestampPrecisionUtils.java | 57 ++++ .../java/org/apache/iotdb/db/wal/node/WALNode.java | 4 + .../apache/iotdb/db/wal/utils/WALEntryHandler.java | 9 +- .../iotdb/db/wal/utils/WALEntryPosition.java | 15 +- .../iotdb/db/wal/utils/WALInsertNodeCache.java | 6 +- .../engine/compaction/AbstractCompactionTest.java | 4 +- .../engine/compaction/CompactionSchedulerTest.java | 96 +++---- .../CompactionSchedulerWithFastPerformerTest.java | 96 +++---- .../db/engine/compaction/MemoryControlTest.java | 137 +++++++++- .../cross/CrossSpaceCompactionSelectorTest.java | 46 ++++ ...eCompactionWithFastPerformerValidationTest.java | 22 +- ...actionWithReadPointPerformerValidationTest.java | 18 +- .../cross/RewriteCompactionFileSelectorTest.java | 15 +- .../inner/InnerCompactionSchedulerTest.java | 10 +- .../inner/InnerSpaceCompactionSelectorTest.java | 2 +- .../SizeTieredCompactionSelectorTest.java | 9 +- .../compaction/utils/CompactionConfigRestorer.java | 4 +- .../db/engine/settle/SettleRequestHandlerTest.java | 6 +- .../db/engine/storagegroup/DataRegionTest.java | 10 +- .../iotdb/db/wal/buffer/WALBufferCommonTest.java | 1 + .../db/wal/checkpoint/CheckpointManagerTest.java | 1 + .../iotdb/db/wal/node/ConsensusReqReaderTest.java | 2 + .../iotdb/db/wal/node/WALEntryHandlerTest.java | 156 ++++++++--- .../org/apache/iotdb/db/wal/node/WALNodeTest.java | 2 + .../db/wal/recover/WALRecoverManagerTest.java | 2 + site/iotdb-doap.rdf | 10 +- 108 files changed, 2015 insertions(+), 660 deletions(-)
