This is an automated email from the ASF dual-hosted git repository.
jackietien pushed a change to branch ty/TableModelGrammar
in repository https://gitbox.apache.org/repos/asf/iotdb.git
from 725503f12ee add relational-grammar
add c8419ec7fc9 Pipe: Ensure at-least-once semantic by forcibly starting
PipeHistoricalDataRegionTsFileExtractor after pipe restart (#12010)
add 2f1dac5900f separate the synchronized block of
AbstractCompactionEstimator file info cache (#12019)
add 4230ad16afd Pipe: using clusterId to judge whether the target cluster
is source cluster (#11994)
add bbdca54ed1d Storage Engine: fix wal delete thread exception because
multi thread safety question (#12020)
add f1d718666f1 PBTree: Fix Dead Lock and Refactor write/update inteface
(#11985)
add 8c90117ebc5 Remove sql `merge` (#12021)
add 6943524b000 Load: Trigger last flush time map & tsfile resource
degrading after successful load (#12024)
add 1a10621dabf feat(jdbc):getDouble add type check
add 142f3c81268 Remove infinite retry logic for replica inconsistency to
avoid potential problems (#12028)
add e4ed1964fd6 Pipe: Support "sink.host" and "connector.host" key in
receiver IP specification (#12017)
add 6e5605ba11a Fixed Ratis query not retrying when DataNode restarts
(#12029)
add fd4337eb0af Pipe: support replace and modify mode for alter pipe sql
(#12018)
add 479122a082f Storage Engine: put DeviceCache into the total memory of
the storage engine (#12016)
new fee52239092 Merge remote-tracking branch 'origin/master' into
ty/TableModelGrammar
The 1 revisions listed above as "new" are entirely new to this
repository and will be described in separate emails. The revisions
listed as "add" were already present in the repository and have only
been added to this reference.
Summary of changes:
.../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} | 10 +-
...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 | 13 +-
.../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, 1180 insertions(+), 568 deletions(-)
rename
integration-test/src/test/java/org/apache/iotdb/db/it/{IoTDBFlushQueryMergeIT.java
=> IoTDBFlushQueryIT.java} (98%)
copy
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/connector/payload/{airgap/AirGapOneByteResponse.java
=> evolvable/common/PipeTransferHandshakeConstant.java} (73%)
copy
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/connector/payload/evolvable/request/{PipeTransferHandshakeReq.java
=> PipeTransferHandshakeV1Req.java} (83%)
rename
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/connector/payload/evolvable/request/{PipeTransferHandshakeReq.java
=> PipeTransferHandshakeV2Req.java} (56%)
create mode 100644
iotdb-core/datanode/src/test/java/org/apache/iotdb/db/storageengine/DevicePathCacheTests.java
copy
iotdb-api/pipe-api/src/main/java/org/apache/iotdb/pipe/api/exception/PipeSinkException.java
=>
iotdb-core/node-commons/src/main/java/org/apache/iotdb/commons/pipe/config/constant/SystemConstant.java
(73%)
