This is an automated email from the ASF dual-hosted git repository. jackietien pushed a commit to branch ty/TableModelGrammar in repository https://gitbox.apache.org/repos/asf/iotdb.git
commit fee522390922350c61d6ff297d986a8c48b34811 Merge: 725503f12ee 479122a082f Author: JackieTien97 <[email protected]> AuthorDate: Tue Feb 6 16:52:53 2024 +0800 Merge remote-tracking branch 'origin/master' into ty/TableModelGrammar .../org/apache/iotdb/db/it/IoTDBDeletionIT.java | 51 +---- ...ushQueryMergeIT.java => IoTDBFlushQueryIT.java} | 3 +- .../apache/iotdb/db/it/IoTDBInsertMultiRowIT.java | 1 - .../org/apache/iotdb/db/it/IoTDBMultiDeviceIT.java | 1 - .../db/it/aligned/IoTDBAlignedDataDeletionIT.java | 52 +---- .../iotdb/db/it/auth/IoTDBSystemPermissionIT.java | 2 - .../org/apache/iotdb/pipe/it/IoTDBPipeAlterIT.java | 243 +++++++++++++++++++-- .../iotdb/session/it/IoTDBSessionComplexIT.java | 2 - .../java/org/apache/iotdb/pipe/api/PipeSink.java | 49 +++-- .../java/org/apache/iotdb/pipe/api/PipeSource.java | 42 ++-- .../api/customizer/parameter/PipeParameters.java | 39 ++-- iotdb-client/jdbc/pom.xml | 4 + .../apache/iotdb/jdbc/IoTDBDatabaseMetadata.java | 36 +-- .../org/apache/iotdb/jdbc/IoTDBJDBCResultSet.java | 9 + .../org/apache/iotdb/db/qp/sql/IoTDBSqlParser.g4 | 24 +- .../confignode/persistence/pipe/PipeTaskInfo.java | 73 ++++--- .../impl/pipe/task/AlterPipeProcedureV2.java | 16 +- .../impl/pipe/task/AlterPipeProcedureV2Test.java | 5 +- .../exception/RatisReadUnavailableException.java | 2 +- .../java/org/apache/iotdb/db/conf/IoTDBConfig.java | 23 +- .../org/apache/iotdb/db/conf/IoTDBDescriptor.java | 104 +++++---- .../dataregion/DataRegionStateMachine.java | 10 +- .../db/pipe/agent/runtime/PipeRuntimeAgent.java | 27 ++- .../common/PipeTransferHandshakeConstant.java} | 18 +- ...akeReq.java => PipeTransferHandshakeV1Req.java} | 18 +- ...akeReq.java => PipeTransferHandshakeV2Req.java} | 63 ++++-- .../protocol/airgap/IoTDBAirGapConnector.java | 28 ++- .../async/IoTDBThriftAsyncClientManager.java | 61 +++++- .../thrift/sync/IoTDBThriftSyncClientManager.java | 55 ++++- .../PipeHistoricalDataRegionTsFileExtractor.java | 12 +- .../receiver/thrift/IoTDBThriftReceiverV1.java | 66 +++++- .../pipe/task/builder/PipeDataNodeTaskBuilder.java | 31 ++- .../impl/DataNodeInternalRPCServiceImpl.java | 2 +- .../execution/executor/RegionExecutionResult.java | 9 + .../execution/executor/RegionReadExecutor.java | 23 +- .../execution/load/LoadTsFileManager.java | 2 +- .../cache/schema/DataNodeDevicePathCache.java | 19 +- .../config/executor/ClusterConfigTaskExecutor.java | 28 +-- .../db/queryengine/plan/parser/ASTVisitor.java | 37 +--- .../planner/plan/node/write/DeleteDataNode.java | 5 +- .../planner/plan/node/write/InsertRowNode.java | 5 +- .../planner/plan/node/write/InsertTabletNode.java | 4 +- .../scheduler/FragmentInstanceDispatcherImpl.java | 4 +- .../metadata/pipe/AlterPipeStatement.java | 18 ++ .../impl/pbtree/schemafile/AliasIndexPage.java | 3 +- .../mtree/impl/pbtree/schemafile/ISegment.java | 7 +- .../impl/pbtree/schemafile/ISegmentedPage.java | 11 +- .../mtree/impl/pbtree/schemafile/InternalPage.java | 3 +- .../impl/pbtree/schemafile/SegmentedPage.java | 43 ++-- .../impl/pbtree/schemafile/WrappedSegment.java | 10 +- .../pbtree/schemafile/pagemgr/PageManager.java | 45 +++- .../db/storageengine/dataregion/DataRegion.java | 67 ++++-- .../estimator/AbstractCompactionEstimator.java | 12 +- .../dataregion/modification/Deletion.java | 6 +- .../tsfile/timeindex/DeviceTimeIndex.java | 14 +- .../connector/PipeDataNodeThriftRequestTest.java | 68 +++++- .../iotdb/db/pipe/connector/PipeReceiverTest.java | 4 +- .../db/storageengine/DevicePathCacheTests.java | 67 ++++++ .../resources/conf/iotdb-common.properties | 10 +- .../config/constant/PipeConnectorConstant.java | 2 + .../pipe/config/constant/SystemConstant.java} | 18 +- .../connector/payload/request/PipeRequestType.java | 4 +- .../builtin/connector/iotdb/IoTDBConnector.java | 34 ++- .../src/main/thrift/confignode.thrift | 6 +- .../src/main/thrift/datanode.thrift | 1 + 65 files changed, 1181 insertions(+), 580 deletions(-)
