This is an automated email from the ASF dual-hosted git repository.
Caideyipi pushed a change to branch insert-values-constant-folding
in repository https://gitbox.apache.org/repos/asf/iotdb.git
from ecf6ffe2e50 Merge branch 'master' of https://github.com/apache/iotdb
into insert-values-constant-folding
add f660639add9 [Test] Exclude mock initialization from pipe worker
timeouts (#18886)
add a7b88b1027e [Test] Fix deletion regression test flush control (#18888)
add d2b97bc8455 Reuse DataRegion insert lock for IoTConsensus shutdown
fencing (#18893)
add 330b0c7ca41 [Test] Fix relational session cleanup and invalid
timestamp test setup (#18887)
add aa365aa53f1 [Client] Add Fast Last Query API to C++ session (#18860)
add e492e444a8d [Fix] Preserve table insert errors for rejected fields
(#18880)
add 9b807abb93f [Bugfix] Preserve retained subscription progress after the
last consumer closes (#18894)
add 9a078cc105e [Subscription] Fix WAL replay progress after realtime gaps
(#18895)
add 4e9679da812 feat: support automatic schema creation in Session (#18890)
add 62337565abc feat(load): route decoded tsfile pieces through consensus
(#18698)
add c6f86b52a94 [Subscription] Release uncommitted tablet payloads with
WAL replay (#18866)
add bacbd5a6dc4 Fix ConfigNode client failover with stale candidates
(#18847)
add c9c16af42f6 [Test] Fix dynamic status queries and asynchronous
deletion polling (#18899)
add d1aaa0dd909 Optimize errMsg when set configuration default- #18856
add 4acf90c3d89 [Subscription] Resume realtime delivery after WAL gap
recovery (#18912)
add e28c4ebce7c Fix ObjectWriter accepting segment offsets beyond EOF
(#18907)
add ad1bd47951f Fix tree path quoting in SHOW CREATE VIEW (#18911)
add 5690cec26c2 [Test] Use consistent time units for asynchronous
assertion flushes (#18905)
add 77d59829e14 [Fix] Reject table inserts when all fields fail validation
(#18908)
add 4c34a253927 [Subscription] Preserve writer order and back off on
blocked safe frontiers (#18844)
add f028736f105 Optimize ConfigNode region lookups and reduce metadata
copying (#18902)
add 9bb1f4d14e2 Fix stale IoTConsensus peers after restart during removal
(#18892)
add 10c5f89ba52 [PIPE][Subscription] Fix pipe races and subscription WAL
replay wakeup (#18904)
add 4943c730d7a [Fix] Guard stopped Pipe polling and retain LOAD payloads
until replicated (#18913)
add 2abe6e925eb [Pipe] Refresh credential user IDs and retain privilege
metadata across retries (#18914)
add f709ef52ff5 Avoid eager aggregation type coverage checks on first
query (#18915)
add 8a8a6da57be [Pipe] Avoid quadratic aligned page memory estimation
(#18917)
add 08380be95ae Fixed multiple configNode bugs (#17609)
add 7decea7e619 Merge master into insert-values-constant-folding
No new revisions were added by this update.
Summary of changes:
.../it/cluster/IoTDBNodeStatusFailoverIT.java | 21 +-
...DBRegionMigrateConfigNodeCrashIoTV2BatchIT.java | 2 +
...BRegionMigrateConfigNodeCrashIoTV2StreamIT.java | 2 +
...oTDBRegionMigrateConfigNodeCrashForRatisIT.java | 2 +
.../iotdb/db/it/IoTDBLoadTsFileClusterIT.java | 383 ++++
.../apache/iotdb/db/it/utils/IoTDBTestUtilsIT.java | 136 ++
.../org/apache/iotdb/db/it/utils/TestUtils.java | 147 +-
.../manual/basic/IoTDBPipePermissionIT.java | 8 +-
.../manual/basic/IoTDBPipeWithLoadIT.java | 3 +-
.../manual/enhanced/IoTDBPipeAutoDropIT.java | 71 +-
.../manual/enhanced/IoTDBPipeMetaIT.java | 20 +-
.../treemodel/auto/basic/IoTDBPipeLifeCycleIT.java | 6 +-
.../auto/enhanced/IoTDBPipeAutoDropIT.java | 117 +-
.../treemodel/manual/IoTDBPipeInclusionIT.java | 26 +-
.../manual/IoTDBPipeMetaHistoricalIT.java | 6 +-
.../treemodel/manual/IoTDBPipePermissionIT.java | 12 +-
.../relational/it/db/it/IoTDBDeletionTableIT.java | 24 +-
.../relational/it/db/it/IoTDBInsertTableIT.java | 78 +
.../it/db/it/IoTDBSetConfigurationTableIT.java | 11 +
.../it/insertquery/IoTDBInsertQueryIT.java | 3 +-
.../relational/it/query/recent/IoTDBCteIT.java | 5 +-
.../it/query/recent/IoTExplainAnalyzeIT.java | 5 +-
.../relational/it/schema/IoTDBDatabaseIT.java | 7 +-
.../it/schema/IoTDBDropTableModProgressIT.java | 5 +-
.../relational/it/schema/IoTDBTableDDLHAIT.java | 44 +-
.../iotdb/relational/it/schema/IoTDBTableIT.java | 101 +-
.../it/session/IoTDBSessionRelationalIT.java | 102 +-
.../IoTDBConsensusSubscriptionBasicTableIT.java | 60 +
iotdb-client/client-cpp/src/include/Session.h | 5 +
.../client-cpp/src/rpc/SessionConnection.cpp | 38 +
.../client-cpp/src/rpc/SessionConnection.h | 3 +
iotdb-client/client-cpp/src/session/Session.cpp | 5 +
iotdb-client/client-cpp/test/cpp/sessionIT.cpp | 47 +
.../iotdb/session/AbstractSessionBuilder.java | 2 +
.../java/org/apache/iotdb/session/Session.java | 15 +-
.../apache/iotdb/session/SessionConnection.java | 4 +
.../apache/iotdb/session/TableSessionBuilder.java | 12 +
.../org/apache/iotdb/session/pool/SessionPool.java | 5 +
.../session/pool/TableSessionPoolBuilder.java | 12 +
.../iotdb/session/SessionCacheLeaderTest.java | 79 +-
.../iotdb/confignode/i18n/ConfigNodeMessages.java | 37 +
.../iotdb/confignode/i18n/ProcedureMessages.java | 11 +
.../iotdb/confignode/i18n/ConfigNodeMessages.java | 45 +-
.../iotdb/confignode/i18n/ProcedureMessages.java | 11 +
.../statemachine/ConfigRegionStateMachine.java | 322 +++-
.../iotdb/confignode/manager/load/LoadManager.java | 9 +
.../confignode/manager/load/cache/LoadCache.java | 10 +
.../iotdb/confignode/manager/node/NodeManager.java | 246 ++-
.../pipe/agent/task/PipeConfigNodeSubtask.java | 12 +-
.../partition/DatabasePartitionTable.java | 2 +-
.../persistence/partition/PartitionInfo.java | 21 +-
.../persistence/subscription/SubscriptionInfo.java | 45 +-
.../procedure/env/RegionMaintainHandler.java | 91 +-
.../impl/node/AddConfigNodeProcedure.java | 4 +-
.../impl/node/RemoveDataNodesProcedure.java | 21 +-
.../impl/region/RemoveRegionPeerProcedure.java | 77 +-
.../procedure/state/RemoveRegionPeerState.java | 2 +
.../statemachine/ConfigRegionStateMachineTest.java | 302 ++++
.../load/cache/ConsensusGroupCacheTest.java | 28 +
.../manager/node/NodeManagerRegistrationTest.java | 260 +++
.../pipe/agent/task/PipeConfigNodeSubtaskTest.java | 150 ++
.../iotdb/confignode/persistence/NodeInfoTest.java | 43 +
.../confignode/persistence/PartitionInfoTest.java | 29 +
.../subscription/SubscriptionInfoTest.java | 99 ++
.../procedure/env/RegionMaintainHandlerTest.java | 85 +-
.../procedure/env/RegionReplicaSetLookupTest.java | 195 +++
.../impl/node/RemoveDataNodesProcedureTest.java | 302 ++++
.../region/RemovePeerRestartConsensusTest.java | 634 +++++++
.../impl/region/RestartDuringRemovePeerTest.java | 450 +++++
.../common/request/IndexedConsensusRequest.java | 20 +
.../consensus/iot/IoTConsensusServerImpl.java | 15 +-
.../consensus/iot/WriterSafeFrontierTracker.java | 33 +
.../consensus/iot/log/ConsensusReqReader.java | 8 +
.../logdispatcher/IoTConsensusMemoryManager.java | 6 +-
.../consensus/iot/logdispatcher/LogDispatcher.java | 13 +-
.../subscription/SubscriptionQueueRegistry.java | 54 +-
.../request/IndexedConsensusRequestTest.java | 110 ++
.../iot/StalePeerListRestartReproductionTest.java | 272 +++
.../iot/WriterSafeFrontierTrackerTest.java | 20 +
.../SubscriptionQueueRegistryTest.java | 46 +
.../apache/iotdb/db/i18n/DataNodeMiscMessages.java | 7 +-
.../apache/iotdb/db/i18n/DataNodePipeMessages.java | 4 +
.../iotdb/db/i18n/DataNodeQueryMessages.java | 110 ++
.../iotdb/db/i18n/StorageEngineMessages.java | 206 ++-
.../apache/iotdb/db/i18n/DataNodeMiscMessages.java | 7 +-
.../apache/iotdb/db/i18n/DataNodePipeMessages.java | 4 +
.../iotdb/db/i18n/DataNodeQueryMessages.java | 109 ++
.../iotdb/db/i18n/StorageEngineMessages.java | 200 ++-
.../java/org/apache/iotdb/db/conf/IoTDBConfig.java | 19 +-
.../org/apache/iotdb/db/conf/IoTDBDescriptor.java | 12 +
.../dataregion/DataExecutionVisitor.java | 74 +-
.../dataregion/DataRegionStateMachine.java | 6 +-
.../IoTConsensusDataRegionStateMachine.java | 7 -
.../common/tsfile/PipeTsFileInsertionEvent.java | 26 +-
.../scan/AlignedSinglePageWholeChunkReader.java | 140 +-
.../parser/scan/SinglePageWholeChunkReader.java | 49 +-
.../scan/TsFileInsertionEventScanParser.java | 68 +-
.../iotconsensusv2/IoTConsensusV2Receiver.java | 4 +-
.../resource/tsfile/PipeTsFileResourceManager.java | 13 +-
...istoricalDataRegionTsFileAndDeletionSource.java | 19 +-
.../iotdb/db/protocol/session/IClientSession.java | 10 +
.../iotdb/db/protocol/session/SessionManager.java | 3 +-
.../protocol/thrift/impl/ClientRPCServiceImpl.java | 15 +-
.../impl/DataNodeInternalRPCServiceImpl.java | 38 +-
.../db/queryengine/plan/analyze/AnalyzeUtils.java | 2 +-
.../plan/analyze/ClusterPartitionFetcher.java | 4 +
.../analyze/cache/partition/PartitionCache.java | 10 +
.../plan/analyze/schema/SchemaValidator.java | 22 +
.../execution/config/TableConfigTaskVisitor.java | 46 +
.../metadata/relational/ShowCreateViewTask.java | 3 +-
.../plan/node/DataNodePlanNodeDeserializer.java | 7 +
.../plan/planner/plan/node/PlanVisitor.java | 5 +
.../plan/node/load/LoadPieceConsensusRequest.java | 117 ++
.../plan/node/load/LoadTsFileConsensusNode.java | 937 ++++++++++
.../plan/node/load/LoadTsFileConsensusOp.java | 60 +
.../plan/node/load/LoadTsFilePieceNode.java | 27 +-
.../plan/planner/plan/node/write/InsertNode.java | 5 +
.../fetcher/TableHeaderSchemaValidator.java | 3 +-
.../plan/relational/sql/parser/AstBuilder.java | 5 +
.../plan/scheduler/load/ChunkOffsetCalculator.java | 208 +++
.../scheduler/load/DataPartitionBatchFetcher.java | 154 ++
.../plan/scheduler/load/DataPartitionResolver.java | 100 ++
.../plan/scheduler/load/DataPartitionRouter.java | 144 ++
.../scheduler/load/LoadConsensusSubmitter.java | 262 +++
.../plan/scheduler/load/LoadFallbackHandler.java | 239 +++
.../scheduler/load/LoadTsFileDispatcherImpl.java | 553 +++---
.../plan/scheduler/load/LoadTsFileScheduler.java | 1292 +++++---------
.../plan/scheduler/load/LocalLoadStrategy.java | 241 +++
.../plan/scheduler/load/MemoryBoundedBuffer.java | 64 +
.../plan/scheduler/load/PieceDispatcher.java | 246 +++
.../plan/scheduler/load/TsFileLoadStrategy.java | 46 +
.../plan/scheduler/load/TsFileSplitConsumer.java | 163 ++
.../load/TwoPhaseConsensusLoadStrategy.java | 590 +++++++
.../iotdb/db/storageengine/StorageEngine.java | 97 +-
.../db/storageengine/dataregion/DataRegion.java | 213 ++-
.../dataregion/memtable/AbstractMemTable.java | 4 +-
.../dataregion/snapshot/SnapshotLoader.java | 23 +-
.../dataregion/snapshot/SnapshotTaker.java | 2 +
.../dataregion/wal/buffer/WALEntry.java | 6 +
.../dataregion/wal/buffer/WALEntryType.java | 4 +-
.../dataregion/wal/buffer/WALInfoEntry.java | 6 +
.../dataregion/wal/node/IWALNode.java | 20 +
.../dataregion/wal/node/WALFakeNode.java | 6 +
.../storageengine/dataregion/wal/node/WALNode.java | 76 +-
.../wal/recover/file/TsFilePlanRedoer.java | 4 +-
.../db/storageengine/load/LoadConsensusCompat.java | 49 +
.../db/storageengine/load/LoadStagingDirs.java | 209 +++
.../db/storageengine/load/LoadTaskRetention.java | 183 ++
.../db/storageengine/load/LoadTsFileCleaner.java | 446 +++++
.../db/storageengine/load/LoadTsFileManager.java | 1234 +++++--------
.../db/storageengine/load/LoadTsFileProgress.java | 905 ++++++++++
.../db/storageengine/load/LoadTsFileSnapshot.java | 481 +++++
.../db/storageengine/load/TsFileWriterManager.java | 956 ++++++++++
.../load/memory/LoadTsFileAbstractMemoryBlock.java | 8 +
.../load/memory/LoadTsFileSubMemoryBlock.java | 101 ++
.../load/metrics/LoadPointCountMetrics.java | 86 +
.../load/splitter/AlignedChunkData.java | 612 ++++---
.../splitter/BatchedAlignedValueChunkData.java | 178 +-
.../db/storageengine/load/splitter/ChunkData.java | 150 +-
.../load/splitter/ChunkPayloadRef.java | 205 +++
.../ChunkPayloadUnavailableException.java} | 19 +-
.../storageengine/load/splitter/DeletionData.java | 11 +
.../load/splitter/NonAlignedChunkData.java | 378 ++--
.../load/splitter/SerializedSizes.java | 78 +
.../db/storageengine/load/splitter/TsFileData.java | 28 +-
.../load/splitter/TsFileSplitter.java | 30 +-
.../iotdb/db/storageengine/load/util/LoadUtil.java | 9 +-
.../agent/SubscriptionConsumerAgent.java | 44 +-
.../consensus/ConsensusLogToTabletConverter.java | 28 +
.../consensus/ConsensusPrefetchingQueue.java | 922 +++++++++-
.../ConsensusSubscriptionSetupHandler.java | 36 +-
.../broker/consensus/ProgressWALIterator.java | 73 +-
.../db/subscription/event/SubscriptionEvent.java | 70 +-
.../cache/CachedSubscriptionPollResponse.java | 1 +
.../response/SubscriptionEventSingleResponse.java | 15 +-
.../receiver/SubscriptionReceiverV1.java | 7 +-
.../org/apache/iotdb/db/utils/ObjectWriter.java | 2 +-
.../org/apache/iotdb/db/utils/TypeServices.java | 76 +-
.../write/TsFilePrecalculatedChunkWriter.java | 553 ++++++
.../LoadTsFileSplitPartitionMaxSizeConfigTest.java | 59 +
.../dataregion/IoTConsensusShutdownTest.java | 343 +++-
.../processor/PipeProcessorSubtaskWorkerTest.java | 8 +
.../pipe/event/PipeTsFileInsertionEventTest.java | 125 +-
.../scan/AlignedPageMemoryUsageEstimatorTest.java | 130 ++
.../resource/PipeTsFileResourceManagerTest.java | 52 +
.../queryengine/plan/analyze/AnalyzeUtilsTest.java | 174 ++
.../plan/analyze/cache/PartitionCacheTest.java | 12 +
.../config/PipeAuthenticationIdentityTest.java | 131 ++
.../relational/ShowCreateViewTaskTest.java | 91 +
.../plan/planner/node/load/LoadTsFileNodeTest.java | 4 +-
.../node/load/LoadTsFileConsensusNodeTest.java | 277 +++
.../scheduler/load/DataPartitionRouterTest.java | 171 ++
.../scheduler/load/LoadConsensusSubmitterTest.java | 249 +++
.../load/LoadTsFileDispatcherImplTest.java | 4 +-
.../scheduler/load/LoadTsFileSchedulerTest.java | 148 +-
.../TwoPhaseConsensusLoadStrategyAbortTest.java | 469 +++++
.../storageengine/dataregion/DataRegionTest.java | 19 +
.../InnerSeqCompactionWithFastPerformerTest.java | 3 +-
...nerSeqCompactionWithReadChunkPerformerTest.java | 7 +-
.../dataregion/memtable/TsFileProcessorTest.java | 12 +-
.../wal/recover/file/TsFilePlanRedoerTest.java | 52 +
.../storageengine/load/LoadTsFileCleanerTest.java | 368 ++++
.../load/LoadTsFileManagerDeletionTest.java | 445 +++++
.../load/LoadTsFileManagerSplitCoverageTest.java | 1839 ++++++++++++++++++++
.../storageengine/load/LoadTsFileManagerTest.java | 1184 +++++++++++++
.../storageengine/load/LoadTsFileProgressTest.java | 192 ++
.../storageengine/load/LoadTsFileResumeTest.java | 378 ++++
.../storageengine/load/LoadTsFileSnapshotTest.java | 544 ++++++
.../load/LoadTsFileTableSchemaTest.java | 181 ++
.../load/memory/LoadTsFileSubMemoryBlockTest.java | 113 ++
.../load/splitter/ChunkDataDirectWriteTest.java | 675 ++++++-
.../load/splitter/SerializedSizesTest.java | 70 +
.../db/storageengine/load/util/LoadUtilTest.java | 19 +
.../ConsensusLogToTabletConverterTest.java | 25 +
...onsensusPrefetchingQueueDataNodeMemoryTest.java | 21 +-
.../ConsensusPrefetchingQueueDeliveryTest.java | 786 +++++++++
.../ConsensusPrefetchingQueueSeekTest.java | 84 +-
.../consensus/ConsensusPrefetchingQueueTest.java | 179 +-
...nsensusPrefetchingQueueWalBackpressureTest.java | 270 ++-
...onsensusPrefetchingQueueWriterOrderingTest.java | 521 ++++++
.../broker/consensus/ProgressWALIteratorTest.java | 52 +-
.../apache/iotdb/db/utils/ObjectWriterTest.java | 84 +
.../apache/iotdb/db/utils/TypeServicesTest.java | 10 +
.../conf/iotdb-system.properties.template | 6 +
.../commons/client/AbstractConfigNodeClient.java | 12 +-
.../commons/queryengine/common/SessionInfo.java | 23 +-
.../plan/planner/plan/node/PlanNodeType.java | 1 +
.../iotdb/commons/request/IConsensusRequest.java | 13 +
.../meta/consumer/CommitProgressKeeper.java | 68 +-
.../meta/consumer/ConsumerGroupMeta.java | 37 +-
.../AbstractConfigNodeClientConnectionTest.java | 340 ++++
.../client/AbstractConfigNodeClientTest.java | 312 ++++
.../consumer/ConsumerGroupDeSerTest.java | 39 +
.../meta/consumer/CommitProgressKeeperTest.java | 26 +
234 files changed, 29061 insertions(+), 3519 deletions(-)
create mode 100644
integration-test/src/test/java/org/apache/iotdb/db/it/IoTDBLoadTsFileClusterIT.java
create mode 100644
integration-test/src/test/java/org/apache/iotdb/db/it/utils/IoTDBTestUtilsIT.java
create mode 100644
iotdb-core/confignode/src/test/java/org/apache/iotdb/confignode/consensus/statemachine/ConfigRegionStateMachineTest.java
create mode 100644
iotdb-core/confignode/src/test/java/org/apache/iotdb/confignode/manager/node/NodeManagerRegistrationTest.java
create mode 100644
iotdb-core/confignode/src/test/java/org/apache/iotdb/confignode/manager/pipe/agent/task/PipeConfigNodeSubtaskTest.java
create mode 100644
iotdb-core/confignode/src/test/java/org/apache/iotdb/confignode/procedure/env/RegionReplicaSetLookupTest.java
create mode 100644
iotdb-core/confignode/src/test/java/org/apache/iotdb/confignode/procedure/impl/region/RemovePeerRestartConsensusTest.java
create mode 100644
iotdb-core/confignode/src/test/java/org/apache/iotdb/confignode/procedure/impl/region/RestartDuringRemovePeerTest.java
create mode 100644
iotdb-core/consensus/src/test/java/org/apache/iotdb/consensus/common/request/IndexedConsensusRequestTest.java
create mode 100644
iotdb-core/consensus/src/test/java/org/apache/iotdb/consensus/iot/StalePeerListRestartReproductionTest.java
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/planner/plan/node/load/LoadPieceConsensusRequest.java
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/planner/plan/node/load/LoadTsFileConsensusNode.java
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/planner/plan/node/load/LoadTsFileConsensusOp.java
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/scheduler/load/ChunkOffsetCalculator.java
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/scheduler/load/DataPartitionBatchFetcher.java
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/scheduler/load/DataPartitionResolver.java
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/scheduler/load/DataPartitionRouter.java
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/scheduler/load/LoadConsensusSubmitter.java
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/scheduler/load/LoadFallbackHandler.java
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/scheduler/load/LocalLoadStrategy.java
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/scheduler/load/MemoryBoundedBuffer.java
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/scheduler/load/PieceDispatcher.java
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/scheduler/load/TsFileLoadStrategy.java
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/scheduler/load/TsFileSplitConsumer.java
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/scheduler/load/TwoPhaseConsensusLoadStrategy.java
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/storageengine/load/LoadConsensusCompat.java
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/storageengine/load/LoadStagingDirs.java
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/storageengine/load/LoadTaskRetention.java
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/storageengine/load/LoadTsFileCleaner.java
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/storageengine/load/LoadTsFileProgress.java
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/storageengine/load/LoadTsFileSnapshot.java
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/storageengine/load/TsFileWriterManager.java
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/storageengine/load/memory/LoadTsFileSubMemoryBlock.java
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/storageengine/load/metrics/LoadPointCountMetrics.java
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/storageengine/load/splitter/ChunkPayloadRef.java
copy
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/{exception/sql/StatementAnalyzeException.java
=> storageengine/load/splitter/ChunkPayloadUnavailableException.java} (58%)
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/storageengine/load/splitter/SerializedSizes.java
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/tsfile/write/TsFilePrecalculatedChunkWriter.java
create mode 100644
iotdb-core/datanode/src/test/java/org/apache/iotdb/db/conf/LoadTsFileSplitPartitionMaxSizeConfigTest.java
create mode 100644
iotdb-core/datanode/src/test/java/org/apache/iotdb/db/pipe/event/common/tsfile/parser/scan/AlignedPageMemoryUsageEstimatorTest.java
create mode 100644
iotdb-core/datanode/src/test/java/org/apache/iotdb/db/queryengine/plan/execution/config/PipeAuthenticationIdentityTest.java
create mode 100644
iotdb-core/datanode/src/test/java/org/apache/iotdb/db/queryengine/plan/execution/config/metadata/relational/ShowCreateViewTaskTest.java
create mode 100644
iotdb-core/datanode/src/test/java/org/apache/iotdb/db/queryengine/plan/planner/plan/node/load/LoadTsFileConsensusNodeTest.java
create mode 100644
iotdb-core/datanode/src/test/java/org/apache/iotdb/db/queryengine/plan/scheduler/load/DataPartitionRouterTest.java
create mode 100644
iotdb-core/datanode/src/test/java/org/apache/iotdb/db/queryengine/plan/scheduler/load/LoadConsensusSubmitterTest.java
create mode 100644
iotdb-core/datanode/src/test/java/org/apache/iotdb/db/queryengine/plan/scheduler/load/TwoPhaseConsensusLoadStrategyAbortTest.java
create mode 100644
iotdb-core/datanode/src/test/java/org/apache/iotdb/db/storageengine/load/LoadTsFileCleanerTest.java
create mode 100644
iotdb-core/datanode/src/test/java/org/apache/iotdb/db/storageengine/load/LoadTsFileManagerDeletionTest.java
create mode 100644
iotdb-core/datanode/src/test/java/org/apache/iotdb/db/storageengine/load/LoadTsFileManagerSplitCoverageTest.java
create mode 100644
iotdb-core/datanode/src/test/java/org/apache/iotdb/db/storageengine/load/LoadTsFileManagerTest.java
create mode 100644
iotdb-core/datanode/src/test/java/org/apache/iotdb/db/storageengine/load/LoadTsFileProgressTest.java
create mode 100644
iotdb-core/datanode/src/test/java/org/apache/iotdb/db/storageengine/load/LoadTsFileResumeTest.java
create mode 100644
iotdb-core/datanode/src/test/java/org/apache/iotdb/db/storageengine/load/LoadTsFileSnapshotTest.java
create mode 100644
iotdb-core/datanode/src/test/java/org/apache/iotdb/db/storageengine/load/LoadTsFileTableSchemaTest.java
create mode 100644
iotdb-core/datanode/src/test/java/org/apache/iotdb/db/storageengine/load/memory/LoadTsFileSubMemoryBlockTest.java
create mode 100644
iotdb-core/datanode/src/test/java/org/apache/iotdb/db/storageengine/load/splitter/SerializedSizesTest.java
create mode 100644
iotdb-core/datanode/src/test/java/org/apache/iotdb/db/subscription/broker/consensus/ConsensusPrefetchingQueueDeliveryTest.java
create mode 100644
iotdb-core/datanode/src/test/java/org/apache/iotdb/db/subscription/broker/consensus/ConsensusPrefetchingQueueWriterOrderingTest.java
create mode 100644
iotdb-core/datanode/src/test/java/org/apache/iotdb/db/utils/ObjectWriterTest.java
create mode 100644
iotdb-core/node-commons/src/test/java/org/apache/iotdb/commons/client/AbstractConfigNodeClientConnectionTest.java
create mode 100644
iotdb-core/node-commons/src/test/java/org/apache/iotdb/commons/client/AbstractConfigNodeClientTest.java
