You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@iotdb.apache.org by ji...@apache.org on 2024/09/19 02:04:59 UTC
(iotdb) 01/01: Merge branch 'rc/1.3.3' into deletion_expr
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 <jt...@163.com>
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(-)