This is an automated email from the ASF dual-hosted git repository. jiangtian pushed a commit to branch deletion_expr in repository https://gitbox.apache.org/repos/asf/iotdb.git
commit 5a859c800abd49b9905c17fb206f2e5c8396630c Merge: f91f273486e 7434fb76e07 Author: Tian Jiang <[email protected]> AuthorDate: Thu Sep 19 10:05:07 2024 +0800 Merge branch 'rc/1.3.3' into deletion_expr .../org/apache/iotdb/it/env/MultiEnvFactory.java | 11 +- .../iotdb/it/env/cluster/ClusterConstant.java | 10 - .../org/apache/iotdb/it/env/cluster/EnvUtils.java | 74 +- .../iotdb/it/env/cluster/env/AbstractEnv.java | 284 ++++---- .../iotdb/it/env/cluster/env/MultiClusterEnv.java | 8 +- .../it/env/cluster/node/AbstractNodeWrapper.java | 2 +- .../it/env/cluster/node/ConfigNodeWrapper.java | 35 +- .../iotdb/it/env/cluster/node/DataNodeWrapper.java | 32 +- .../db/it/last/IoTDBLastQueryLastCacheIT.java | 14 + .../it/last/IoTDBLastQueryWithLimitOffsetIT.java | 34 + .../apache/iotdb/it/framework/IoTDBTestRunner.java | 21 +- .../iotdb/pipe/it/single/IoTDBPipeOPCUAIT.java | 6 + .../api/customizer/parameter/PipeParameters.java | 4 + iotdb-client/client-py/SessionExample.py | 53 +- iotdb-client/client-py/iotdb/Session.py | 31 + .../client-py/iotdb/tsfile/utils/DateUtils.py | 41 ++ iotdb-client/client-py/iotdb/utils/Field.py | 50 +- .../client-py/iotdb/utils/IoTDBConstants.py | 11 +- .../client-py/iotdb/utils/IoTDBRpcDataSet.py | 93 ++- iotdb-client/client-py/iotdb/utils/NumpyTablet.py | 33 +- iotdb-client/client-py/iotdb/utils/RowRecord.py | 8 +- .../client-py/iotdb/utils/SessionDataSet.py | 24 +- iotdb-client/client-py/iotdb/utils/Tablet.py | 44 +- .../tests/integration/test_new_data_types.py | 157 ++++ .../iotdb/consensus/ratis/RatisConsensus.java | 9 + .../java/org/apache/iotdb/db/conf/IoTDBConfig.java | 15 + .../org/apache/iotdb/db/conf/IoTDBDescriptor.java | 34 +- .../client/IoTDBDataNodeAsyncClientManager.java | 12 +- .../evolvable/batch/PipeTabletEventBatch.java | 4 +- .../batch/PipeTransferBatchReqBuilder.java | 6 +- .../connector/protocol/opcua/OpcUaNameSpace.java | 1 + .../protocol/opcua/OpcUaServerBuilder.java | 150 ++-- .../async/IoTDBDataRegionAsyncConnector.java | 7 +- .../thrift/sync/IoTDBDataRegionSyncConnector.java | 4 +- .../common/tsfile/PipeTsFileInsertionEvent.java | 29 +- .../PipeHistoricalDataRegionTsFileExtractor.java | 26 +- .../realtime/assigner/PipeDataRegionAssigner.java | 29 +- .../PipeTimePartitionProgressIndexKeeper.java | 100 +++ .../db/pipe/metric/PipeDataRegionEventCounter.java | 6 +- .../resource/memory/InsertNodeMemoryEstimator.java | 802 +++++++++++++++++++++ .../pipe/task/builder/PipeDataNodeTaskBuilder.java | 57 +- .../subtask/connector/PipeConnectorSubtask.java | 12 +- .../connector/PipeConnectorSubtaskLifeCycle.java | 5 +- .../connector/PipeConnectorSubtaskManager.java | 6 +- .../PipeRealtimePriorityBlockingQueue.java | 7 +- .../protocol/rest/v1/impl/RestApiServiceImpl.java | 8 +- .../protocol/rest/v2/impl/RestApiServiceImpl.java | 11 +- .../plan/analyze/LoadTsFileAnalyzer.java | 11 +- .../plan/planner/LogicalPlanVisitor.java | 11 +- .../plan/node/process/last/LastQueryNode.java | 3 + .../plan/node/write/InsertMultiTabletsNode.java | 2 +- .../plan/planner/plan/node/write/InsertNode.java | 6 +- .../planner/plan/node/write/InsertRowsNode.java | 14 +- .../plan/node/write/InsertRowsOfOneDeviceNode.java | 2 +- .../apache/iotdb/db/schemaengine/SchemaEngine.java | 60 +- .../java/org/apache/iotdb/db/service/DataNode.java | 101 ++- .../db/storageengine/dataregion/DataRegion.java | 6 + .../task/RepairUnsortedFileCompactionTask.java | 63 +- .../impl/NewSizeTieredCompactionSelector.java | 7 +- .../memtable/AlignedWritableMemChunk.java | 2 +- .../dataregion/memtable/TsFileProcessor.java | 59 +- .../dataregion/tsfile/TsFileManager.java | 14 + .../dataregion/tsfile/TsFileResource.java | 11 +- .../dataregion/wal/utils/WALInsertNodeCache.java | 44 +- .../load/active/ActiveLoadDirScanner.java | 47 ++ .../load/active/ActiveLoadTsFileLoader.java | 19 +- .../SubscriptionConnectorSubtaskLifeCycle.java | 2 +- .../SubscriptionConnectorSubtaskManager.java | 6 +- .../tools/schema/SchemaRegionSnapshotParser.java | 68 +- .../org/apache/iotdb/db/utils/DateTimeUtils.java | 2 + .../db/pipe/extractor/PipeRealtimeExtractTest.java | 7 + .../logical/DataQueryLogicalPlannerTest.java | 33 + .../TsFileResourceProgressIndexTest.java | 10 +- .../dataregion/memtable/TsFileProcessorTest.java | 124 +++- .../commons/consensus/index/ProgressIndex.java | 34 +- .../consensus/index/impl/HybridProgressIndex.java | 27 +- .../consensus/index/impl/IoTProgressIndex.java | 25 +- .../consensus/index/impl/MetaProgressIndex.java | 8 +- .../consensus/index/impl/MinimumProgressIndex.java | 7 +- .../consensus/index/impl/RecoverProgressIndex.java | 25 +- .../consensus/index/impl/SimpleProgressIndex.java | 12 +- .../consensus/index/impl/StateProgressIndex.java | 22 +- .../index/impl/TimeWindowStateProgressIndex.java | 17 +- .../pipe/connector/protocol/IoTDBConnector.java | 2 +- .../iotdb/commons/pipe/event/EnrichedEvent.java | 5 + .../pipe/task/connection/BlockingPendingQueue.java | 5 +- 86 files changed, 2667 insertions(+), 676 deletions(-)
