This is an automated email from the ASF dual-hosted git repository.
shuwenwei pushed a change to branch table_disk_usage_statistics_with_cache
in repository https://gitbox.apache.org/repos/asf/iotdb.git
from 774407a72c0 Merge branch 'iotdb_master' into
table_disk_usage_statistics_with_cache
add 0c9916c02a0 fix copilot review comments
add a434fa7c237 Pipe: Fixed the bug that a realtime only pipe will not
transfer historical data when it is altered to a historical pipe (#17223)
add 3b6aa45b18b fix start.cli on java 8 (#17228)
add ea3cff508bf Memory estimate refine for TableScanOperator (#17230)
add b2246339211 Fixed TsFileProcessorTest may check the result before the
TsFile is closed (#17232)
add 36c7db80d15 fix redundant operations in compaction (#17239)
add 80ecbe6017e Bump com.fasterxml.jackson.core:jackson-core from 2.16.2
to 2.18.6 (#17235)
add 72e9e6e2554 Fix checkstyle line length violation in
SubscriptionException (#17129)
add 9c11cfdbaa4 Fix refactor/s3024 stringbuilder append (#17234)
add 449838f3608 Consensus pipe skip login (#17242)
add 19d76707bc2 Fixed the quote problem in "as" clause in view && Fixed
the bug that the device may not be able to be queried from cache (#17241)
add 6ec3a5144b1 Pipe: Configured the air gap timeout to avoid packet loss
(#17231)
add 35ef0c8ba42 Fix deadlock between DataNode createDataRegion and
ConfigNode PipeTaskCoordinatorLock by delegating consensus pipe lifecycle to
ConfigNode (#17233)
add cd8f3db12a2 Fixed that InsertionCompactionSelection may skip a file
deleted by another compaction (#17254)
add 942477843dc Pipe: Fixed the bug that the default
"enable-send-tsfile-limit" is set to false for historical pipes split by full
sync (#17264)
add 9acf1e9ed73 Fix conflict config plan type (#17260)
add bd74ad3b43b Update release info after 2.0.7 released (#17275)
add 00127279cf1 Add 3C3D IoTConsensusV2 integration tests (#17257)
add ea3cc3cbdef Cpp client supports visual studio 2026 (#17218)
add 902bc60352f Pipe: Fixed the crashed VM for ITs & Added watcher thread
for dataNode start (#17281)
add e7f80974364 Introduce delay analyzer to get watermark between sequence
data and unsequece data based on ICDE 2022 (#16886)
add a53f960e25c Fix the duplicate literals using the constant (#17274)
add 77cf7564701 [AINode] Renew AINode docker package script (#17289)
add 68ca0a7f0fc Fix incorrect early termination in descending scan of
unpackOneFakeMemChunkMetaData (#17283)
add 9a67740018a [IoTV2] Add ConfigNode-side consensus pipe guardian and
remove deprecated DataNode-side checking (#17277)
add ccece97de76 rename pipe consensus to iot consensus v2 (#17291)
add a7c541d4c99 Use PartitionRecognizer and PartitionCache to handle
window function's partition. (#17280)
add ca741cb9df9 Merge branch 'iotdb_master' into
table_disk_usage_statistics_with_cache
No new revisions were added by this update.
Summary of changes:
.dockerignore | 2 +
.github/workflows/daily-it.yml | 60 +--
.github/workflows/multi-language-client.yml | 8 +-
.mvn/wrapper/maven-wrapper.properties | 2 +-
README.md | 2 +-
README_ZH.md | 2 +-
RELEASE_NOTES.md | 47 ++
dependencies.json | 18 +-
docker/ReadMe.md | 20 +
.../main/DockerCompose/docker-compose-ainode.yml | 3 +
docker/src/main/Dockerfile-1.0.0-ainode | 66 ---
docker/src/main/Dockerfile-2.0.x-ainode | 88 ++++
docker/src/main/ainode-entrypoint.sh | 150 +++++++
docker/src/main/build-ainode.sh | 270 ++++++++++++
example/client-cpp-example/pom.xml | 4 +-
.../org/apache/iotdb/TableModelJDBCExample.java | 7 +-
.../java/org/apache/iotdb/SessionPoolExample.java | 2 +-
.../org/apache/iotdb/TableModelSessionExample.java | 7 +-
.../apache/iotdb/TableModelSessionPoolExample.java | 9 +-
integration-test/pom.xml | 56 +--
.../iotdb/it/env/cluster/ClusterConstant.java | 62 +--
.../org/apache/iotdb/it/env/cluster/EnvUtils.java | 24 +-
.../it/env/cluster/config/MppCommonConfig.java | 4 +-
.../env/cluster/config/MppSharedCommonConfig.java | 6 +-
.../iotdb/it/env/cluster/env/AbstractEnv.java | 33 +-
.../it/env/cluster/node/AbstractNodeWrapper.java | 50 ++-
.../it/env/remote/config/RemoteCommonConfig.java | 2 +-
.../org/apache/iotdb/itbase/env/CommonConfig.java | 2 +-
.../itbase/runtime/ClusterTestConnection.java | 10 +-
.../iotdb/itbase/runtime/ClusterTestResultSet.java | 14 +-
.../iotdb/itbase/runtime/ClusterTestStatement.java | 11 +-
.../itbase/runtime/ParallelRequestDelegate.java | 9 +-
.../org/apache/iotdb/db/it/IoTDBFlushQueryIT.java | 23 +
.../IoTDBIoTConsensusV23C3DBasicITBase.java | 298 +++++++++++++
.../IoTDBIoTConsensusV2Batch3C3DBasicIT.java} | 26 +-
.../IoTDBIoTConsensusV2Stream3C3DBasicIT.java} | 26 +-
.../treemodel/auto/basic/IoTDBPipeAlterIT.java | 45 ++
.../view/recent/IoTDBComplexQueryTableViewIT.java | 18 +-
.../iotdb/relational/it/schema/IoTDBTableIT.java | 54 +--
iotdb-client/client-cpp/pom.xml | 16 +-
.../java/org/apache/iotdb/rpc/TSStatusCode.java | 16 +-
.../iotdb/confignode/conf/ConfigNodeConfig.java | 11 +
.../confignode/conf/ConfigNodeDescriptor.java | 3 +
.../consensus/request/ConfigPhysicalPlanType.java | 1 -
.../iotdb/confignode/manager/ProcedureManager.java | 32 ++
.../pipe/coordinator/runtime/PipeMetaSyncer.java | 20 +
.../pipe/coordinator/task/PipeTaskCoordinator.java | 20 +-
.../coordinator/task/PipeTaskCoordinatorLock.java | 19 +-
.../PipeConfigNodeCopiedFileDirStartupCleaner.java | 8 +-
.../subscription/SubscriptionCoordinator.java | 10 +-
.../persistence/auth/AuthorPlanExecutor.java | 2 -
.../persistence/executor/ConfigPlanExecutor.java | 1 -
.../confignode/persistence/pipe/PipeTaskInfo.java | 14 +
.../procedure/env/RegionMaintainHandler.java | 334 +++++++++++++-
.../impl/pipe/task/AlterPipeProcedureV2.java | 8 +-
.../impl/region/AddRegionPeerProcedure.java | 5 +
.../impl/region/CreateRegionGroupsProcedure.java | 6 +
.../impl/region/RemoveRegionPeerProcedure.java | 45 +-
.../procedure/state/AddRegionPeerState.java | 1 +
.../procedure/state/CreateRegionGroupsState.java | 5 +-
.../procedure/state/RemoveRegionPeerState.java | 1 +
...lyPlan.java => ConfigPhysicalPlanTypeTest.java} | 33 +-
.../pipe/PipeTaskInfoConsensusPipeTest.java | 152 +++++++
.../RegionMaintainHandlerConsensusPipeTest.java | 290 +++++++++++++
.../apache/iotdb/consensus/ConsensusFactory.java | 9 +-
.../iotdb/consensus/config/ConsensusConfig.java | 20 +-
...sensusConfig.java => IoTConsensusV2Config.java} | 77 +---
.../{PipeConsensus.java => IoTConsensusV2.java} | 132 ++----
...Manager.java => IoTConsensusV2PeerManager.java} | 6 +-
...rverImpl.java => IoTConsensusV2ServerImpl.java} | 308 +++----------
.../consensuspipe/ConsensusPipeDispatcher.java | 42 --
.../pipe/consensuspipe/ConsensusPipeGuardian.java | 26 --
.../pipe/consensuspipe/ConsensusPipeManager.java | 157 -------
.../pipe/consensuspipe/ConsensusPipeReceiver.java | 6 +-
.../pipe/consensuspipe/ConsensusPipeSelector.java | 28 --
...trics.java => IoTConsensusV2ServerMetrics.java} | 38 +-
...ager.java => IoTConsensusV2SyncLagManager.java} | 24 +-
...CService.java => IoTConsensusV2RPCService.java} | 35 +-
...r.java => IoTConsensusV2RPCServiceHandler.java} | 6 +-
...ean.java => IoTConsensusV2RPCServiceMBean.java} | 2 +-
...java => IoTConsensusV2RPCServiceProcessor.java} | 71 ++-
.../java/org/apache/iotdb/db/conf/IoTDBConfig.java | 58 +++
.../org/apache/iotdb/db/conf/IoTDBDescriptor.java | 50 ++-
.../db/consensus/DataRegionConsensusImpl.java | 29 +-
.../PipeDataRegionProcessorConstructor.java | 6 +-
.../dataregion/PipeDataRegionSinkConstructor.java | 10 +-
.../agent/receiver/PipeDataNodeReceiverAgent.java | 14 +-
.../agent/runtime/PipeDataNodeRuntimeAgent.java | 4 +-
.../db/pipe/agent/task/PipeDataNodeTaskAgent.java | 21 -
.../task/builder/PipeDataNodeTaskBuilder.java | 3 +-
.../agent/task/connection/PipeEventCollector.java | 2 +-
.../task/execution/PipeSubtaskExecutorManager.java | 8 +-
.../subtask/processor/PipeProcessorSubtask.java | 4 +-
.../consensus/ConsensusPipeDataNodeDispatcher.java | 131 ------
.../ConsensusPipeDataNodeRuntimeAgentGuardian.java | 48 --
...tor.java => IoTConsensusV2SubtaskExecutor.java} | 6 +-
.../ReplicateProgressDataNodeManager.java | 8 +-
.../pipe/consensus/deletion/DeletionResource.java | 2 +-
.../deletion/DeletionResourceManager.java | 12 +-
.../deletion/persist/PageCacheDeletionBuffer.java | 4 +-
...ics.java => IoTConsensusV2ReceiverMetrics.java} | 76 ++--
...Metrics.java => IoTConsensusV2SinkMetrics.java} | 60 +--
.../tsfile/PipeCompactedTsFileInsertionEvent.java | 4 +-
.../common/tsfile/PipeTsFileInsertionEvent.java | 16 +-
.../IoTConsensusV2Processor.java} | 6 +-
.../IoTConsensusV2Receiver.java} | 482 +++++++++++----------
.../IoTConsensusV2ReceiverAgent.java} | 87 ++--
...aNodeHardlinkOrCopiedFileDirStartupCleaner.java | 8 +-
.../protocol/airgap/IoTDBDataRegionAirGapSink.java | 5 +
.../IoTConsensusV2AsyncSink.java} | 222 +++++-----
.../IoTConsensusV2SyncSink.java} | 156 +++----
.../handler/IoTConsensusV2DeleteEventHandler.java} | 42 +-
.../IoTConsensusV2TabletBatchEventHandler.java} | 56 +--
...oTConsensusV2TabletInsertNodeEventHandler.java} | 28 +-
...IoTConsensusV2TabletInsertionEventHandler.java} | 39 +-
...IoTConsensusV2TsFileInsertionEventHandler.java} | 79 ++--
.../IoTConsensusV2AsyncBatchReqBuilder.java} | 6 +-
.../IoTConsensusV2SyncBatchReqBuilder.java} | 8 +-
.../IoTConsensusV2TransferBatchReqBuilder.java} | 34 +-
.../request/IoTConsensusV2DeleteNodeReq.java} | 32 +-
.../request/IoTConsensusV2TabletBatchReq.java} | 37 +-
.../request/IoTConsensusV2TabletBinaryReq.java} | 32 +-
.../IoTConsensusV2TabletInsertNodeReq.java} | 36 +-
.../request/IoTConsensusV2TsFilePieceReq.java} | 36 +-
.../IoTConsensusV2TsFilePieceWithModReq.java} | 38 +-
.../request/IoTConsensusV2TsFileSealReq.java} | 36 +-
.../IoTConsensusV2TsFileSealWithModReq.java} | 36 +-
.../source/dataregion/IoTDBDataRegionSource.java | 31 +-
...istoricalDataRegionTsFileAndDeletionSource.java | 10 +-
.../realtime/assigner/PipeDataRegionAssigner.java | 8 +-
.../common/header/DatasetHeaderFactory.java | 2 +-
.../process/function/partition/PartitionCache.java | 10 +
.../rowpattern/PatternPartitionExecutor.java | 36 +-
.../process/window/TableWindowOperator.java | 254 ++++-------
.../process/window/partition/Partition.java | 213 ++++-----
.../window/partition/PartitionExecutor.java | 49 ++-
.../operator/schema/source/DeviceSchemaSource.java | 2 +-
.../execution/operator/source/SeriesScanUtil.java | 64 ++-
.../relational/AbstractTableScanOperator.java | 10 +-
.../config/executor/ClusterConfigTaskExecutor.java | 11 +-
.../metadata/relational/ShowCreateViewTask.java | 2 +-
.../plan/planner/OperatorTreeGenerator.java | 2 +-
.../node/metadata/read/DevicesSchemaScanNode.java | 24 +-
.../planner/plan/node/process/CollectNode.java | 14 -
.../metadata/fetcher/TableDeviceSchemaFetcher.java | 12 +-
.../sql/ast/AbstractQueryDeviceWithCache.java | 15 +-
.../plan/relational/sql/parser/AstBuilder.java | 30 +-
.../read/resp/info/impl/ShowDevicesResult.java | 4 +-
.../java/org/apache/iotdb/db/service/DataNode.java | 93 ++--
.../iotdb/db/service/DataNodeShutdownHook.java | 2 +-
.../iotdb/db/storageengine/StorageEngine.java | 2 +-
.../db/storageengine/dataregion/DataRegion.java | 62 ++-
.../performer/impl/FastCompactionPerformer.java | 7 -
.../compaction/execute/utils/CompactionUtils.java | 14 +-
.../execute/utils/MultiTsFileDeviceIterator.java | 93 +---
.../fast/FastAlignedSeriesCompactionExecutor.java | 18 +-
.../impl/RewriteCrossSpaceCompactionSelector.java | 6 +
.../dataregion/memtable/TsFileProcessor.java | 53 +--
.../dataregion/tsfile/TsFileResource.java | 18 +-
.../db/storageengine/load/LoadTsFileManager.java | 4 +-
.../subtask/SubscriptionSinkSubtaskManager.java | 3 +-
.../org/apache/iotdb/db/tools/DelayAnalyzer.java | 387 +++++++++++++++++
.../PipeDataNodeSnapshotResourceManagerTest.java | 12 +-
.../source/relational/TableScanOperatorTest.java | 113 +++++
.../logical/SchemaQueryLogicalPlannerTest.java | 6 +-
.../dataregion/memtable/TsFileProcessorTest.java | 158 -------
.../apache/iotdb/db/tools/DelayAnalyzerTest.java | 361 +++++++++++++++
.../conf/iotdb-system.properties.template | 32 ++
.../iotdb/commons/client/ClientPoolFactory.java | 44 +-
....java => AsyncIoTConsensusV2ServiceClient.java} | 24 +-
...erty.java => IoTConsensusV2ClientProperty.java} | 22 +-
...t.java => SyncIoTConsensusV2ServiceClient.java} | 26 +-
.../iotdb/commons/concurrent/ThreadName.java | 32 +-
.../apache/iotdb/commons/conf/CommonConfig.java | 21 +
.../container/IoTV2GlobalComponentContainer.java | 40 +-
...susV2RetryWithIncreasingIntervalException.java} | 4 +-
.../agent/plugin/builtin/BuiltinPipePlugin.java | 17 +-
.../IoTConsensusV2Processor.java} | 8 +-
...AsyncSink.java => IoTConsensusV2AsyncSink.java} | 6 +-
.../agent/task/subtask/PipeReportableSubtask.java | 4 +-
.../iotdb/commons/pipe/config/PipeConfig.java | 4 +
.../iotdb/commons/pipe/config/PipeDescriptor.java | 7 +
.../iotdb/commons/pipe/event/EnrichedEvent.java | 4 +-
.../pipe/receiver/PipeReceiverStatusHandler.java | 4 +-
.../request/IoTConsensusV2RequestType.java} | 20 +-
.../request/IoTConsensusV2RequestVersion.java} | 6 +-
.../IoTConsensusV2TransferFilePieceReq.java} | 20 +-
.../IoTConsensusV2TransferFileSealReq.java} | 22 +-
.../IoTConsensusV2TransferFileSealWithModReq.java} | 20 +-
.../IoTConsensusV2TransferFilePieceResp.java} | 30 +-
.../schema/column/ColumnHeaderConstant.java | 2 +-
.../commons/schema/table/InformationSchema.java | 2 +-
.../apache/iotdb/commons/service/ServiceType.java | 2 +-
.../iotdb/commons/service/metric/enums/Metric.java | 4 +-
.../org/apache/iotdb/commons/utils/RetryUtils.java | 6 +-
iotdb-doap.rdf | 48 ++
...{pipeconsensus.thrift => iotconsensusv2.thrift} | 24 +-
pom.xml | 6 +-
scripts/sbin/windows/start-cli.bat | 18 +-
199 files changed, 5175 insertions(+), 3266 deletions(-)
delete mode 100644 docker/src/main/Dockerfile-1.0.0-ainode
create mode 100644 docker/src/main/Dockerfile-2.0.x-ainode
create mode 100644 docker/src/main/ainode-entrypoint.sh
create mode 100644 docker/src/main/build-ainode.sh
create mode 100644
integration-test/src/test/java/org/apache/iotdb/db/it/iotconsensusv2/IoTDBIoTConsensusV23C3DBasicITBase.java
copy
integration-test/src/test/java/org/apache/iotdb/{confignode/it/regionmigration/pass/daily/datanodecrash/iotv1/IoTDBRegionMigrateOriginalCrashWhenDeleteLocalPeerForIoTV1IT.java
=> db/it/iotconsensusv2/batch/IoTDBIoTConsensusV2Batch3C3DBasicIT.java} (61%)
copy
integration-test/src/test/java/org/apache/iotdb/{confignode/it/regionmigration/pass/daily/datanodecrash/iotv1/IoTDBRegionMigrateOriginalCrashWhenDeleteLocalPeerForIoTV1IT.java
=> db/it/iotconsensusv2/stream/IoTDBIoTConsensusV2Stream3C3DBasicIT.java} (60%)
copy
iotdb-core/confignode/src/test/java/org/apache/iotdb/confignode/consensus/request/{TestOnlyPlan.java
=> ConfigPhysicalPlanTypeTest.java} (58%)
create mode 100644
iotdb-core/confignode/src/test/java/org/apache/iotdb/confignode/persistence/pipe/PipeTaskInfoConsensusPipeTest.java
create mode 100644
iotdb-core/confignode/src/test/java/org/apache/iotdb/confignode/procedure/env/RegionMaintainHandlerConsensusPipeTest.java
rename
iotdb-core/consensus/src/main/java/org/apache/iotdb/consensus/config/{PipeConsensusConfig.java
=> IoTConsensusV2Config.java} (76%)
rename
iotdb-core/consensus/src/main/java/org/apache/iotdb/consensus/pipe/{PipeConsensus.java
=> IoTConsensusV2.java} (78%)
rename
iotdb-core/consensus/src/main/java/org/apache/iotdb/consensus/pipe/{PipeConsensusPeerManager.java
=> IoTConsensusV2PeerManager.java} (90%)
rename
iotdb-core/consensus/src/main/java/org/apache/iotdb/consensus/pipe/{PipeConsensusServerImpl.java
=> IoTConsensusV2ServerImpl.java} (59%)
delete mode 100644
iotdb-core/consensus/src/main/java/org/apache/iotdb/consensus/pipe/consensuspipe/ConsensusPipeDispatcher.java
delete mode 100644
iotdb-core/consensus/src/main/java/org/apache/iotdb/consensus/pipe/consensuspipe/ConsensusPipeGuardian.java
delete mode 100644
iotdb-core/consensus/src/main/java/org/apache/iotdb/consensus/pipe/consensuspipe/ConsensusPipeManager.java
delete mode 100644
iotdb-core/consensus/src/main/java/org/apache/iotdb/consensus/pipe/consensuspipe/ConsensusPipeSelector.java
rename
iotdb-core/consensus/src/main/java/org/apache/iotdb/consensus/pipe/metric/{PipeConsensusServerMetrics.java
=> IoTConsensusV2ServerMetrics.java} (84%)
rename
iotdb-core/consensus/src/main/java/org/apache/iotdb/consensus/pipe/metric/{PipeConsensusSyncLagManager.java
=> IoTConsensusV2SyncLagManager.java} (85%)
rename
iotdb-core/consensus/src/main/java/org/apache/iotdb/consensus/pipe/service/{PipeConsensusRPCService.java
=> IoTConsensusV2RPCService.java} (70%)
rename
iotdb-core/consensus/src/main/java/org/apache/iotdb/consensus/pipe/service/{PipeConsensusRPCServiceHandler.java
=> IoTConsensusV2RPCServiceHandler.java} (86%)
rename
iotdb-core/consensus/src/main/java/org/apache/iotdb/consensus/pipe/service/{PipeConsensusRPCServiceMBean.java
=> IoTConsensusV2RPCServiceMBean.java} (94%)
rename
iotdb-core/consensus/src/main/java/org/apache/iotdb/consensus/pipe/service/{PipeConsensusRPCServiceProcessor.java
=> IoTConsensusV2RPCServiceProcessor.java} (75%)
delete mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/consensus/ConsensusPipeDataNodeDispatcher.java
delete mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/consensus/ConsensusPipeDataNodeRuntimeAgentGuardian.java
rename
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/consensus/{PipeConsensusSubtaskExecutor.java
=> IoTConsensusV2SubtaskExecutor.java} (93%)
rename
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/consensus/metric/{PipeConsensusReceiverMetrics.java
=> IoTConsensusV2ReceiverMetrics.java} (83%)
rename
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/consensus/metric/{PipeConsensusSinkMetrics.java
=> IoTConsensusV2SinkMetrics.java} (82%)
rename
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/processor/{pipeconsensus/PipeConsensusProcessor.java
=> iotconsensusv2/IoTConsensusV2Processor.java} (97%)
rename
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/receiver/protocol/{pipeconsensus/PipeConsensusReceiver.java
=> iotconsensusv2/IoTConsensusV2Receiver.java} (75%)
rename
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/receiver/protocol/{pipeconsensus/PipeConsensusReceiverAgent.java
=> iotconsensusv2/IoTConsensusV2ReceiverAgent.java} (72%)
rename
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/sink/protocol/{pipeconsensus/PipeConsensusAsyncSink.java
=> iotconsensusv2/IoTConsensusV2AsyncSink.java} (71%)
rename
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/sink/protocol/{pipeconsensus/PipeConsensusSyncSink.java
=> iotconsensusv2/IoTConsensusV2SyncSink.java} (74%)
rename
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/sink/protocol/{pipeconsensus/handler/PipeConsensusDeleteEventHandler.java
=> iotconsensusv2/handler/IoTConsensusV2DeleteEventHandler.java} (71%)
rename
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/sink/protocol/{pipeconsensus/handler/PipeConsensusTabletBatchEventHandler.java
=> iotconsensusv2/handler/IoTConsensusV2TabletBatchEventHandler.java} (61%)
rename
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/sink/protocol/{pipeconsensus/handler/PipeConsensusTabletInsertNodeEventHandler.java
=> iotconsensusv2/handler/IoTConsensusV2TabletInsertNodeEventHandler.java}
(53%)
rename
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/sink/protocol/{pipeconsensus/handler/PipeConsensusTabletInsertionEventHandler.java
=> iotconsensusv2/handler/IoTConsensusV2TabletInsertionEventHandler.java} (75%)
rename
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/sink/protocol/{pipeconsensus/handler/PipeConsensusTsFileInsertionEventHandler.java
=> iotconsensusv2/handler/IoTConsensusV2TsFileInsertionEventHandler.java} (74%)
rename
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/sink/protocol/{pipeconsensus/payload/builder/PipeConsensusAsyncBatchReqBuilder.java
=> iotconsensusv2/payload/builder/IoTConsensusV2AsyncBatchReqBuilder.java}
(85%)
rename
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/sink/protocol/{pipeconsensus/payload/builder/PipeConsensusSyncBatchReqBuilder.java
=> iotconsensusv2/payload/builder/IoTConsensusV2SyncBatchReqBuilder.java} (81%)
rename
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/sink/protocol/{pipeconsensus/payload/builder/PipeConsensusTransferBatchReqBuilder.java
=> iotconsensusv2/payload/builder/IoTConsensusV2TransferBatchReqBuilder.java}
(85%)
rename
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/sink/protocol/{pipeconsensus/payload/request/PipeConsensusDeleteNodeReq.java
=> iotconsensusv2/payload/request/IoTConsensusV2DeleteNodeReq.java} (75%)
rename
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/sink/protocol/{pipeconsensus/payload/request/PipeConsensusTabletBatchReq.java
=> iotconsensusv2/payload/request/IoTConsensusV2TabletBatchReq.java} (54%)
rename
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/sink/protocol/{pipeconsensus/payload/request/PipeConsensusTabletBinaryReq.java
=> iotconsensusv2/payload/request/IoTConsensusV2TabletBinaryReq.java} (74%)
rename
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/sink/protocol/{pipeconsensus/payload/request/PipeConsensusTabletInsertNodeReq.java
=> iotconsensusv2/payload/request/IoTConsensusV2TabletInsertNodeReq.java} (75%)
rename
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/sink/protocol/{pipeconsensus/payload/request/PipeConsensusTsFilePieceReq.java
=> iotconsensusv2/payload/request/IoTConsensusV2TsFilePieceReq.java} (57%)
rename
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/sink/protocol/{pipeconsensus/payload/request/PipeConsensusTsFilePieceWithModReq.java
=> iotconsensusv2/payload/request/IoTConsensusV2TsFilePieceWithModReq.java}
(55%)
rename
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/sink/protocol/{pipeconsensus/payload/request/PipeConsensusTsFileSealReq.java
=> iotconsensusv2/payload/request/IoTConsensusV2TsFileSealReq.java} (59%)
rename
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/sink/protocol/{pipeconsensus/payload/request/PipeConsensusTsFileSealWithModReq.java
=> iotconsensusv2/payload/request/IoTConsensusV2TsFileSealWithModReq.java}
(60%)
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/tools/DelayAnalyzer.java
create mode 100644
iotdb-core/datanode/src/test/java/org/apache/iotdb/db/queryengine/execution/operator/source/relational/TableScanOperatorTest.java
create mode 100644
iotdb-core/datanode/src/test/java/org/apache/iotdb/db/tools/DelayAnalyzerTest.java
rename
iotdb-core/node-commons/src/main/java/org/apache/iotdb/commons/client/async/{AsyncPipeConsensusServiceClient.java
=> AsyncIoTConsensusV2ServiceClient.java} (84%)
rename
iotdb-core/node-commons/src/main/java/org/apache/iotdb/commons/client/property/{PipeConsensusClientProperty.java
=> IoTConsensusV2ClientProperty.java} (81%)
rename
iotdb-core/node-commons/src/main/java/org/apache/iotdb/commons/client/sync/{SyncPipeConsensusServiceClient.java
=> SyncIoTConsensusV2ServiceClient.java} (82%)
rename
iotdb-core/node-commons/src/main/java/org/apache/iotdb/commons/exception/pipe/{PipeConsensusRetryWithIncreasingIntervalException.java
=> IoTConsensusV2RetryWithIncreasingIntervalException.java} (85%)
rename
iotdb-core/node-commons/src/main/java/org/apache/iotdb/commons/pipe/agent/plugin/builtin/processor/{pipeconsensus/PipeConsensusProcessor.java
=> iotconsensusv2/IoTConsensusV2Processor.java} (82%)
rename
iotdb-core/node-commons/src/main/java/org/apache/iotdb/commons/pipe/agent/plugin/builtin/sink/iotdb/consensus/{PipeConsensusAsyncSink.java
=> IoTConsensusV2AsyncSink.java} (84%)
rename
iotdb-core/node-commons/src/main/java/org/apache/iotdb/commons/pipe/sink/payload/{pipeconsensus/request/PipeConsensusRequestType.java
=> iotconsensusv2/request/IoTConsensusV2RequestType.java} (70%)
rename
iotdb-core/node-commons/src/main/java/org/apache/iotdb/commons/pipe/sink/payload/{pipeconsensus/request/PipeConsensusRequestVersion.java
=> iotconsensusv2/request/IoTConsensusV2RequestVersion.java} (85%)
rename
iotdb-core/node-commons/src/main/java/org/apache/iotdb/commons/pipe/sink/payload/{pipeconsensus/request/PipeConsensusTransferFilePieceReq.java
=> iotconsensusv2/request/IoTConsensusV2TransferFilePieceReq.java} (83%)
rename
iotdb-core/node-commons/src/main/java/org/apache/iotdb/commons/pipe/sink/payload/{pipeconsensus/request/PipeConsensusTransferFileSealReq.java
=> iotconsensusv2/request/IoTConsensusV2TransferFileSealReq.java} (83%)
rename
iotdb-core/node-commons/src/main/java/org/apache/iotdb/commons/pipe/sink/payload/{pipeconsensus/request/PipeConsensusTransferFileSealWithModReq.java
=> iotconsensusv2/request/IoTConsensusV2TransferFileSealWithModReq.java} (88%)
rename
iotdb-core/node-commons/src/main/java/org/apache/iotdb/commons/pipe/sink/payload/{pipeconsensus/response/PipeConsensusTransferFilePieceResp.java
=> iotconsensusv2/response/IoTConsensusV2TransferFilePieceResp.java} (71%)
rename iotdb-protocol/thrift-consensus/src/main/thrift/{pipeconsensus.thrift
=> iotconsensusv2.thrift} (81%)
