You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@iotdb.apache.org by ja...@apache.org on 2024/02/06 08:53:07 UTC
(iotdb) 01/01: Merge remote-tracking branch 'origin/master' into ty/TableModelGrammar
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 <ja...@gmail.com>
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(-)