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 2026/07/09 07:22:34 UTC
(iotdb) 01/02: Merge branch 'master' into table_insert_tablets
This is an automated email from the ASF dual-hosted git repository.
jt2594838 pushed a commit to branch table_insert_tablets
in repository https://gitbox.apache.org/repos/asf/iotdb.git
commit afbea6c558d18022f8d48289776a8e4e51e54dc9
Merge: e7eefcdc1c5 f3e161218d6
Author: Tian Jiang <jt...@163.com>
AuthorDate: Thu Jul 9 11:35:29 2026 +0800
Merge branch 'master' into table_insert_tablets
.../it/database/IoTDBDatabaseRegionControlIT.java | 111 ++++
.../commit/IoTDBMigrateMultiRegionForIoTV1IT.java | 66 +++
...TDBRegionMigrateWithDeletionMultiDataDirIT.java | 14 +-
...gionMigrateWithDeletionMultiDataDirTableIT.java | 14 +-
.../RegionMigrateFileAssertions.java | 2 +-
.../IoTDBRegionMigrateNormalITForIoTV2BatchIT.java | 34 ++
.../manual/enhanced/IoTDBPipeDoubleLivingIT.java | 10 +-
.../IoTDBPipeReceiverAutoCreateDisabledIT.java | 37 ++
.../relational/it/db/it/IoTDBDeletionTableIT.java | 565 ++++++++++++++++++++-
.../it/db/it/IoTDBLoadConfigurationTableIT.java | 110 ++++
.../schema/IoTDBDatabaseMaxRegionGroupNumIT.java | 73 +++
.../java/org/apache/iotdb/jdbc/StringUtils.java | 21 +-
.../org/apache/iotdb/jdbc/StringUtilsTest.java | 74 +++
.../iotdb/confignode/i18n/ManagerMessages.java | 3 +
.../iotdb/confignode/i18n/ProcedureMessages.java | 2 +
.../iotdb/confignode/i18n/ManagerMessages.java | 3 +
.../iotdb/confignode/i18n/ProcedureMessages.java | 2 +
.../load/cache/region/RegionGroupCache.java | 8 +-
.../pipe/coordinator/task/PipeTaskCoordinator.java | 30 +-
.../receiver/protocol/IoTDBConfigNodeReceiver.java | 56 +-
.../pipe/source/IoTDBConfigRegionSource.java | 21 +-
.../manager/schema/ClusterSchemaManager.java | 36 +-
.../procedure/impl/StateMachineProcedure.java | 13 +-
.../PipeConfigTreePrivilegeParseVisitorTest.java | 43 ++
.../confignode/procedure/STMProcedureTest.java | 70 +++
.../pipe/AbstractOperatePipeProcedureV2Test.java | 3 +-
.../consensus/iot/IoTConsensusServerImpl.java | 13 +-
.../apache/iotdb/db/i18n/DataNodeMiscMessages.java | 4 +-
.../apache/iotdb/db/i18n/DataNodePipeMessages.java | 18 +-
.../iotdb/db/i18n/DataNodeQueryMessages.java | 70 ++-
.../iotdb/db/i18n/StorageEngineMessages.java | 2 +
.../apache/iotdb/db/i18n/DataNodeMiscMessages.java | 2 +-
.../apache/iotdb/db/i18n/DataNodePipeMessages.java | 18 +-
.../iotdb/db/i18n/DataNodeQueryMessages.java | 58 ++-
.../iotdb/db/i18n/StorageEngineMessages.java | 2 +
.../org/apache/iotdb/db/conf/IoTDBDescriptor.java | 38 +-
.../DirectBufferMemoryAllocationException.java} | 24 +-
.../db/pipe/agent/task/PipeDataNodeTaskAgent.java | 455 +++--------------
.../task/builder/PipeDataNodeTaskBuilder.java | 36 ++
.../agent/task/connection/PipeEventCollector.java | 15 +-
.../agent/task/stage/PipeTaskProcessorStage.java | 5 +-
.../subtask/processor/PipeProcessorSubtask.java | 2 +
.../common/tsfile/PipeTsFileInsertionEvent.java | 144 ++++--
.../tsfile/parser/TsFileInsertionEventParser.java | 12 +-
.../query/TsFileInsertionEventQueryParser.java | 1 +
.../scan/TsFileInsertionEventScanParser.java | 14 +-
.../table/TsFileInsertionEventTableParser.java | 22 +-
.../processor/aggregate/AggregateProcessor.java | 3 +
.../downsampling/DownSamplingProcessor.java | 3 +
.../receiver/TwoStageAggregateReceiver.java | 10 +
.../exchange/sender/TwoStageAggregateSender.java | 75 ++-
.../twostage/plugin/TwoStageCountProcessor.java | 9 +-
.../protocol/thrift/IoTDBDataNodeReceiver.java | 178 ++++++-
.../db/pipe/resource/memory/PipeMemoryManager.java | 95 +++-
.../evolvable/batch/PipeTabletEventBatch.java | 69 ++-
.../evolvable/batch/PipeTabletEventPlainBatch.java | 61 ++-
.../batch/PipeTabletEventTsFileBatch.java | 30 +-
.../protocol/airgap/IoTDBDataRegionAirGapSink.java | 18 +-
.../iotconsensusv2/IoTConsensusV2SyncSink.java | 20 +-
.../IoTConsensusV2TsFileInsertionEventHandler.java | 34 +-
.../IoTConsensusV2TransferBatchReqBuilder.java | 109 ++--
.../sink/protocol/legacy/IoTDBLegacyPipeSink.java | 17 +-
.../async/handler/PipeTransferTsFileHandler.java | 42 +-
.../thrift/sync/IoTDBDataRegionSyncSink.java | 136 +++++
...istoricalDataRegionTsFileAndDeletionSource.java | 31 +-
.../realtime/PipeRealtimeDataRegionSource.java | 17 +-
.../schemaregion/IoTDBSchemaRegionSource.java | 4 +-
.../PipePlanTablePrivilegeParseVisitor.java | 17 +
.../protocol/thrift/impl/ClientRPCServiceImpl.java | 42 +-
.../impl/DataNodeInternalRPCServiceImpl.java | 4 +-
.../db/queryengine/common/MPPQueryContext.java | 286 ++++++++++-
.../common/schematree/ClusterSchemaTree.java | 8 +
.../db/queryengine/plan/analyze/AnalyzeUtils.java | 436 ++++++++++++++--
.../queryengine/plan/analyze/AnalyzeVisitor.java | 8 +
.../queryengine/plan/analyze/ExpressionUtils.java | 2 +
.../analyze/schema/ClusterSchemaFetchExecutor.java | 9 +
.../config/executor/ClusterConfigTaskExecutor.java | 25 +-
.../relational/analyzer/StatementAnalyzer.java | 2 +-
.../read_tsfile/ExternalTsFileQueryResource.java | 9 +-
.../tvf/read_tsfile/ReadTsFileTableFunction.java | 60 ++-
.../plan/relational/planner/RelationPlanner.java | 5 +-
.../plan/relational/sql/ast/DeleteDevice.java | 5 +-
.../db/schemaengine/table/DataNodeTableCache.java | 2 +-
.../iotdb/db/storageengine/StorageEngine.java | 18 +-
.../db/storageengine/dataregion/DataRegion.java | 26 +-
.../compaction/execute/utils/CompactionUtils.java | 2 +-
.../memtable/AlignedWritableMemChunk.java | 92 +++-
.../dataregion/modification/DeletionPredicate.java | 46 +-
.../modification/TableDeletionEntry.java | 6 +-
.../{IDPredicate.java => TagPredicate.java} | 261 ++++++++--
.../dataregion/tsfile/TsFileResource.java | 41 +-
.../file/UnsealedTsFileRecoverPerformer.java | 2 +-
.../iotdb/db/metadata/path/PatternTreeMapTest.java | 2 +-
.../pipe/agent/task/PipeDataNodeTaskAgentTest.java | 88 ----
.../db/pipe/consensus/DeletionRecoverTest.java | 2 +-
.../db/pipe/consensus/DeletionResourceTest.java | 2 +-
.../pipe/event/TsFileInsertionEventParserTest.java | 154 ++++++
.../iotdb/db/pipe/sink/PipeReceiverTest.java | 70 ++-
.../PipeTabletEventPlainBatchPerformanceTest.java | 137 +++++
.../PipePlanTablePatternParseVisitorTest.java | 57 ++-
.../db/pipe/source/PipeRealtimeExtractTest.java | 73 +++
.../db/queryengine/common/MPPQueryContextTest.java | 125 +++++
.../queryengine/plan/analyze/AnalyzeUtilsTest.java | 6 +-
.../node/write/RelationalDeleteDataNodeTest.java | 8 +-
.../ExternalTsFileQueryResourceTest.java | 7 +-
.../schemaengine/table/DataNodeTableCacheTest.java | 20 +
.../iotdb/db/storageengine/StorageEngineTest.java | 45 ++
.../storageengine/dataregion/DataRegionTest.java | 2 +-
.../tablemodel/CompactionWithAllNullRowsTest.java | 12 +-
.../modification/ModificationFileTest.java | 27 +-
.../modification/TableDeletionEntryTest.java | 48 +-
.../dataregion/tsfile/TsFileResourceTest.java | 19 +-
.../conf/iotdb-system.properties.template | 2 +-
.../apache/iotdb/commons/i18n/PipeMessages.java | 2 +
.../apache/iotdb/commons/i18n/UtilMessages.java | 2 +
.../apache/iotdb/commons/i18n/PipeMessages.java | 2 +
.../apache/iotdb/commons/i18n/UtilMessages.java | 2 +
.../apache/iotdb/commons/disk/FolderManager.java | 30 +-
.../MinFolderOccupiedSpaceFirstStrategy.java | 3 +-
.../pipe/config/constant/PipeSourceConstant.java | 41 ++
.../env/PipeTaskProcessorRuntimeEnvironment.java | 23 +
.../datastructure/visibility/VisibilityUtils.java | 9 +-
.../commons/pipe/receiver/IoTDBFileReceiver.java | 103 +++-
.../thrift/common/PipeTransferSliceReqHandler.java | 37 ++
.../thrift/request/PipeTransferCompressedReq.java | 21 +
.../iotdb/commons/pipe/source/IoTDBSource.java | 18 +-
.../apache/iotdb/commons/utils/JVMCommonUtils.java | 30 +-
...FolderOccupiedSpaceFirstStrategyRealFsTest.java | 61 +++
.../visibility/VisibilityUtilsTest.java | 24 +
.../pipe/receiver/IoTDBFileReceiverTest.java | 184 ++++++-
.../common/PipeTransferSliceReqBuilderTest.java | 52 ++
.../request/PipeTransferCompressedReqTest.java | 37 ++
.../iotdb/commons/utils/JVMCommonUtilsTest.java | 48 ++
133 files changed, 5226 insertions(+), 1160 deletions(-)