This is an automated email from the ASF dual-hosted git repository. haonan pushed a commit to branch opt_aligned_tvlist in repository https://gitbox.apache.org/repos/asf/iotdb.git
commit 504e5b3532a8ffaadf20fc523056d83a24a7a718 Merge: cdac597412b 51fe585dfcd Author: HTHou <[email protected]> AuthorDate: Wed Aug 27 10:58:38 2025 +0800 Merge branch 'master' of github.com:apache/iotdb into opt_aligned_tvlist .../it/env/cluster/config/MppCommonConfig.java | 12 + .../env/cluster/config/MppSharedCommonConfig.java | 13 + .../iotdb/it/env/cluster/env/AbstractEnv.java | 37 +- .../it/env/remote/config/RemoteCommonConfig.java | 10 + .../iotdb/it/env/remote/env/RemoteServerEnv.java | 6 + .../java/org/apache/iotdb/itbase/env/BaseEnv.java | 13 + .../org/apache/iotdb/itbase/env/CommonConfig.java | 4 + ...T.java => IoTDBPartitionInheritStrategyIT.java} | 4 +- .../partition/IoTDBPartitionShuffleStrategyIT.java | 140 ++++ ...IoTDBRegionOperationReliabilityITFramework.java | 5 +- .../IoTDBRegionMigrateDataNodeCrashForIoTV1IT.java | 15 +- ...BRegionMigrateDataNodeCrashForIoTV2BatchIT.java | 13 +- ...RegionMigrateDataNodeCrashForIoTV2StreamIT.java | 13 +- .../IoTDBRegionMigrateClusterCrashIoTV1IT.java | 3 +- ...IoTDBRegionMigrateClusterCrashIoTV2BatchIT.java | 6 +- ...DBRegionMigrateConfigNodeCrashIoTV2BatchIT.java | 9 +- ...oTDBRegionMigrateClusterCrashIoTV2StreamIT.java | 9 +- ...BRegionMigrateConfigNodeCrashIoTV2StreamIT.java | 9 +- .../iotdb/db/it/IoTDBCustomizedClusterIT.java | 22 +- .../org/apache/iotdb/db/it/IoTDBLoadTsFileIT.java | 83 ++ .../iotdb/db/it/auth/IoTDBGrantOptionIT.java | 81 ++ .../manual/enhanced/IoTDBPipeMetaIT.java | 25 +- .../auto/enhanced/IoTDBPipeSinkCompressionIT.java | 22 +- .../it/insertquery/IoTDBInsertQueryIT.java | 33 + .../it/query/recent/IoTDBTableAggregationIT.java | 52 ++ .../org/apache/iotdb/tool/common/Constants.java | 2 + .../iotdb/tool/schema/ExportSchemaTable.java | 44 +- .../client-cpp/src/example/MultiSvrNodeClient.cpp | 147 ++++ .../client-cpp/src/main/AbstractSessionBuilder.h | 4 + iotdb-client/client-cpp/src/main/Common.cpp | 44 + iotdb-client/client-cpp/src/main/Common.h | 18 + iotdb-client/client-cpp/src/main/NodesSupplier.cpp | 100 +-- iotdb-client/client-cpp/src/main/NodesSupplier.h | 1 + iotdb-client/client-cpp/src/main/Session.cpp | 86 +- iotdb-client/client-cpp/src/main/Session.h | 14 +- .../{TableSessionBuilder.h => SessionBuilder.h} | 68 +- .../client-cpp/src/main/SessionConnection.cpp | 2 + .../client-cpp/src/main/SessionConnection.h | 3 +- .../client-cpp/src/main/TableSessionBuilder.h | 4 + iotdb-client/client-cpp/src/test/cpp/sessionIT.cpp | 96 +++ .../src/test/cpp/sessionRelationalIT.cpp | 24 + .../{scheduler => dispatcher}/__init__.py | 0 .../abstract_dispatcher.py} | 26 + .../core/inference/dispatcher/basic_dispatcher.py | 60 ++ .../core/inference/inference_request_pool.py | 12 +- .../ainode/core/inference/pool_controller.py | 155 ++-- ...ference_request_pool_group.py => pool_group.py} | 32 +- .../ainode/ainode/core/inference/pool_scheduler.py | 125 --- .../{scheduler => pool_scheduler}/__init__.py | 0 .../pool_scheduler/abstract_pool_scheduler.py | 56 ++ .../pool_scheduler/basic_pool_scheduler.py | 59 ++ .../ainode/core/inference/request_controller.py | 89 -- .../{scheduler => request_scheduler}/__init__.py | 0 .../abstract_request_scheduler.py} | 2 +- .../basic_request_scheduler.py} | 9 +- .../ainode/core/manager/inference_manager.py | 56 +- iotdb-core/ainode/ainode/core/manager/utils.py | 8 +- .../async/handlers/rpc/PipePushMetaRPCHandler.java | 2 +- .../iotdb/confignode/conf/ConfigNodeConfig.java | 10 + .../confignode/conf/ConfigNodeDescriptor.java | 4 + .../confignode/conf/SystemPropertiesUtils.java | 12 +- .../exception/NoAvailableRegionGroupException.java | 14 +- .../manager/load/balancer/PartitionBalancer.java | 194 +++-- .../manager/partition/PartitionManager.java | 2 +- .../runtime/heartbeat/PipeHeartbeatParser.java | 2 +- .../confignode/persistence/pipe/PipeTaskInfo.java | 2 +- .../confignode/procedure/ProcedureExecutor.java | 7 +- .../java/org/apache/iotdb/db/conf/IoTDBConfig.java | 20 + .../org/apache/iotdb/db/conf/IoTDBDescriptor.java | 13 + .../agent/runtime/PipeDataNodeRuntimeAgent.java | 7 +- .../scan/TsFileInsertionEventScanParser.java | 45 +- .../table/TsFileInsertionEventTableParser.java | 15 +- ...ileInsertionEventTableParserTabletIterator.java | 45 +- .../processor/aggregate/AggregateProcessor.java | 5 +- .../pipeconsensus/PipeConsensusReceiver.java | 114 ++- .../visitor/PipePlanToStatementVisitor.java | 6 +- .../resource/memory/InsertNodeMemoryEstimator.java | 10 +- .../source/dataregion/IoTDBDataRegionSource.java | 16 +- .../listener/PipeInsertionDataNodeListener.java | 5 +- .../matcher/CachedSchemaPatternMatcher.java | 180 ++-- .../db/pipe/source/mqtt/MQTTPublishHandler.java | 21 +- .../iotdb/db/pipe/source/mqtt/MQTTSource.java | 102 ++- .../protocol/rest/v2/impl/RestApiServiceImpl.java | 43 +- .../protocol/thrift/impl/ClientRPCServiceImpl.java | 10 + .../db/queryengine/common/MPPQueryContext.java | 7 +- .../queryengine/execution/driver/DataDriver.java | 44 +- .../fragment/FakedFragmentInstanceContext.java | 5 +- .../fragment/FragmentInstanceContext.java | 244 ++++-- .../fragment/FragmentInstanceExecution.java | 4 +- .../InformationSchemaContentSupplierFactory.java | 193 ++--- .../AbstractApproxPercentileAccumulator.java | 164 ++++ .../relational/aggregation/AccumulatorFactory.java | 14 + .../aggregation/ApproxPercentileAccumulator.java | 119 +++ .../ApproxPercentileWithWeightAccumulator.java | 125 +++ .../aggregation/approximate/TDigest.java | 915 +++++++++++++++++++++ ...AbstractGroupedApproxPercentileAccumulator.java | 149 ++++ .../GroupedApproxCountDistinctAccumulator.java | 12 +- .../GroupedApproxPercentileAccumulator.java | 144 ++++ ...oupedApproxPercentileWithWeightAccumulator.java | 149 ++++ .../aggregation/grouped/array/TDigestBigArray.java | 75 ++ .../queryengine/metric/QueryResourceMetricSet.java | 26 +- .../iotdb/db/queryengine/plan/Coordinator.java | 69 +- .../db/queryengine/plan/analyze/Analysis.java | 3 +- .../queryengine/plan/analyze/PredicateUtils.java | 11 +- .../cache/schema/DataNodeDevicePathCache.java | 3 - .../db/queryengine/plan/parser/ASTVisitor.java | 11 + .../plan/planner/TableOperatorGenerator.java | 17 +- .../plan/planner/distribution/SourceRewriter.java | 15 +- .../plan/node/pipe/PipeEnrichedDeleteDataNode.java | 14 +- .../relational/metadata/TableMetadataImpl.java | 37 + .../relational/planner/TableLogicalPlanner.java | 47 +- .../distribute/TableDistributedPlanGenerator.java | 1 + .../plan/relational/planner/node/IntoNode.java | 40 +- .../optimizations/UnaliasSymbolReferences.java | 11 +- .../plan/relational/sql/ast/Delete.java | 3 +- .../plan/relational/sql/parser/AstBuilder.java | 15 + .../FragmentInstanceStatisticsDrawer.java | 11 + .../db/storageengine/dataregion/DataRegion.java | 428 +++++++--- .../dataregion/IDataRegionForQuery.java | 29 +- .../dataregion/VirtualDataRegion.java | 36 +- .../execute/utils/CompactionPathUtils.java | 23 +- .../memtable/AbstractWritableMemChunk.java | 11 + .../dataregion/memtable/TsFileProcessor.java | 65 +- .../dataregion/tsfile/TsFileManager.java | 43 +- .../dataregion/tsfile/TsFileResource.java | 3 +- .../db/storageengine/load/LoadTsFileManager.java | 60 +- .../load/splitter/AlignedChunkData.java | 7 +- .../load/splitter/NonAlignedChunkData.java | 4 + .../iotdb/db/utils/constant/SqlConstant.java | 1 + .../db/utils/datastructure/AlignedTVList.java | 156 +++- .../db/queryengine/execution/DataDriverTest.java | 15 +- .../planner/node/process/IntoNodeSerdeTest.java | 4 + .../apache/iotdb/commons/conf/CommonConfig.java | 40 +- .../iotdb/commons/conf/CommonDescriptor.java | 4 + .../task/progress/interval/PipeCommitInterval.java | 6 +- .../iotdb/commons/pipe/config/PipeConfig.java | 14 +- .../iotdb/commons/pipe/config/PipeDescriptor.java | 14 +- .../pipe/config/constant/PipeSourceConstant.java | 3 +- .../pipe/datastructure/interval/Interval.java | 6 +- .../datastructure/interval/IntervalManager.java | 13 +- .../datastructure/pattern/IoTDBTreePattern.java | 23 +- .../TableBuiltinAggregationFunction.java | 4 +- .../apache/iotdb/commons/utils/StatusUtils.java | 18 +- .../thrift-commons/src/main/thrift/common.thrift | 3 +- .../src/main/thrift/datanode.thrift | 1 + pom.xml | 2 +- 146 files changed, 5307 insertions(+), 1317 deletions(-)
