This is an automated email from the ASF dual-hosted git repository.
caogaofei pushed a change to branch beyyes/count_time_fe
in repository https://gitbox.apache.org/repos/asf/iotdb.git
from bb1e36a6ccb fix count_time having usage
add 4136802f214 Stop generating FilterExpression if we don't specify the
time filter in last query session api
add 2676f2c2b33 Removed front-end request parameters output in Grafana
backend logs (#10784)
add 3f5816aafcd Fixed iotdb common.sh getting null iotdb port (#10781)
add c16b0944297 Optimize leader change event (#10797)
add 862728c2f49 fix: Fixed the name of the profile used to activate the
integration-tests on jenkins. (#10806)
add 0fd475041a6 Multi-Cluster IT framework (#10518)
add e609295edc0 Perfect some error messages of Memorypool
add ad061f96a15 Fix compaction force decoding check (#10801)
add 2cde87171fa Enhance cn_confignode_target_list comments (#10812)
add 644e4a989f5 Totally remove influxdb-protocol related files (#10814)
add 685bfa983c2 Fix compaction log keyword bug (#10785)
add 9fbc0318f47 [IOTDB-6104] Remove tmp directory for udf query completely
while query end
add 63caecc8c36 Fix error log when start confignode and datanode (#10820)
add 1f321df57b7 [To Master] Fixed the prompt after CSV file import (#10824)
add 2e6d9527c04 [IOTDB-6105] Load: NPE when analyzing tsfile (#10821)
add ff3239bf829 [IOTDB-6106] Fixed the timeout parameter not working in
thrift asyncClient (#10822)
add 29d414b2937 session module add UT (#10815)
add 031495a6301 Pipe: refactor connector packages and rename v1/v2 to
sync/async (#10840)
add da7e66db404 fix parameter schemaRegionPerNode load error (#10841)
add 80427a00c5f Enhance the event notification mechanism of
StatisticsService (#10829)
add 59a0dcf11a1 Refactoring DeleteOutdatedFileTask in WalNode (#10765)
add ccd73310fac fix inaccurate statistics for monitoring the number of
unseq Tsfile on cross compaction (#10651)
add 47a14313621 add memory estimator on inner space compaction (#10688)
add 7dd7cf78956 Fix a concurrent bug when recover last flush time and
compact (#10839)
add 3dc1490cfc8 [IOTDB-6108] Fix AlignedTVList memory calculation is
imprecise (#10827)
add 11af323b79d Pipe: Remove parameters from iotdb-common.properties that
users will not modify (#10851)
add 459a394a86b [IOTDB-6113] Load: Fix setDatabase does not print logs and
set failure except DATABASE_ALREADY_EXISTS (#10854)
add 98128a4f02e Update the description of schemaRegionPerNode in
common.properties (#10857)
add 0133c139538 [IOTDB-6111] Fix Region creation bugs (#10844)
add f7ca23cbd00 Fix SchemaFileSketchTool is not found
add cdcb4a691d3 [IOTDB-6112] Fix Limit & Offset push down doesn't take
effect while there exist time filter
add 8e0256658e0 Remove useless dependency bugsnag (#10861)
add b0bd6065a42 Replace dependency commons-lang to commons-lang3
add 621b66a871e Remove useless dependency h2-mvstore
add 44d6bec0f39 Pipe IT: Changed IoTDBPipeDemoIT timeout to 10 mins to
allow pipe-internal retries when unstable cases occuring (#10867)
add 16a9f3fe760 Bump
com.googlecode.maven-download-plugin:download-maven-plugin (#10747)
add 89645c6889f Delete useless airline, concurrent-200 and jaxb-runtime
dependencies (#10866)
add 3e9ddc77c86 Pipe IT: fix the usage of Awaitility.awit (#10869)
add b445540475a [IOTDB-6116] Disassociate the IoTConsensus retry logic
from the forkjoinPool (#10872)
add 679c495b043 [RatisConsensus] Unify read timeout to Thrift connection
timeout (#10876)
add 9acb3594a18 Fix Region migrate bug (#10862)
add 80f9a80e50f [IOTDB-6118] Pipe: Support transfer data through air gap
(IoTDBAirGapConnector) (#10853)
add 0a90c45486d Pipe IT: Stablelized pipe IT by prohibiting exceptions
from assertEqual function (#10881)
add 0b28f31379d fix dataMigrationExample error (#10886)
add 6bef0b0b232 fix: Hopefully fixed the build of the cpp-example on
windows systems (#10891)
add 709e7ef8694 Upgrade guava to avoid vulnerability issue (#10892)
add 052ff28cf89 Override existing jar instead of deleting it when
registering UDF
add 97e083efcec [IOTDB-6115] Fix Limit & Offset push down doesn't take
effect while there exist null value
add a45248d4959 Rename iotdb-thrift module to iotdb-thrift-datanode
(#10884)
add 29e038d6a96 Fix memory leak when deleting database in PB_Tree mode
(#10885)
add 38b36006b2a [IOTDB-6117] Pipe: Optimize RPC requests from CN to DN. CN
send exactly one pipeMeta to each DN upon create/start/stop/drop pipe (#10875)
add 5f6db2e308a Fix some ITs of UDFManagement
add 2c2f40bdb45 Implement intersect with prefix pattern for PartialPath
and PathPatternTree
add ad64b1d5b68 Merge branch 'master' into beyyes/count_time_fe
No new revisions were added by this update.
Summary of changes:
.github/workflows/pipe-it-2cluster.yml | 66 +++
CONTRIBUTING.md | 2 +-
Jenkinsfile | 2 +-
LICENSE-binary | 6 +-
distribution/pom.xml | 6 -
example/client-cpp-example/src/CMakeLists.txt | 10 +-
.../src/main/java/org/apache/iotdb/SSLClient.java | 2 +-
.../org/apache/iotdb/DataMigrationExample.java | 3 +-
integration-test/pom.xml | 113 +++++
.../java/org/apache/iotdb/it/env/EnvFactory.java | 11 +-
.../main/java/org/apache/iotdb/it/env/EnvType.java | 4 +-
.../env/{EnvFactory.java => MultiEnvFactory.java} | 51 +-
.../iotdb/it/env/cluster/ClusterConstant.java | 221 +++++++++
.../iotdb/it/env/cluster/ConfigNodeWrapper.java | 175 -------
.../iotdb/it/env/cluster/DataNodeWrapper.java | 217 --------
.../org/apache/iotdb/it/env/cluster/EnvUtils.java | 140 +++++-
.../it/env/cluster/{ => config}/MppBaseConfig.java | 4 +-
.../env/cluster/{ => config}/MppClusterConfig.java | 2 +-
.../env/cluster/{ => config}/MppCommonConfig.java | 30 +-
.../cluster/{ => config}/MppConfigNodeConfig.java | 2 +-
.../cluster/{ => config}/MppDataNodeConfig.java | 2 +-
.../it/env/cluster/{ => config}/MppJVMConfig.java | 2 +-
.../{ => config}/MppSharedCommonConfig.java | 9 +-
.../it/env/cluster/{ => env}/AbstractEnv.java | 93 +++-
.../it/env/cluster/{ => env}/Cluster1Env.java | 3 +-
.../{Cluster1Env.java => env/MultiClusterEnv.java} | 13 +-
.../iotdb/it/env/cluster/{ => env}/SimpleEnv.java | 2 +-
.../cluster/{ => node}/AbstractNodeWrapper.java | 283 ++++++++---
.../it/env/cluster/node/ConfigNodeWrapper.java | 201 ++++++++
.../iotdb/it/env/cluster/node/DataNodeWrapper.java | 256 ++++++++++
.../remote/{ => config}/RemoteClusterConfig.java | 2 +-
.../remote/{ => config}/RemoteCommonConfig.java | 6 +-
.../{ => config}/RemoteConfigNodeConfig.java | 2 +-
.../remote/{ => config}/RemoteDataNodeConfig.java | 2 +-
.../env/remote/{ => config}/RemoteJVMConfig.java | 2 +-
.../it/env/remote/{ => env}/RemoteServerEnv.java | 8 +-
.../apache/iotdb/it/framework/IoTDBTestRunner.java | 10 +-
.../category/MultiClusterIT1.java} | 5 +-
.../category/MultiClusterIT2.java} | 5 +-
.../category/MultiClusterIT3.java} | 5 +-
.../java/org/apache/iotdb/itbase/env/BaseEnv.java | 4 +-
.../apache/iotdb/itbase/env/BaseNodeWrapper.java | 4 +-
.../org/apache/iotdb/itbase/env/CommonConfig.java | 2 +
.../apache/iotdb/cli/it/StartClientScriptIT.java | 1 +
.../it/cluster/IoTDBClusterNodeErrorStartUpIT.java | 8 +-
.../it/cluster/IoTDBClusterNodeGetterIT.java | 4 +-
.../it/cluster/IoTDBClusterRestartIT.java | 10 +-
.../partition/IoTDBAutoRegionGroupExtensionIT.java | 2 +
.../IoTDBAutoRegionGroupExtensionIT2.java | 160 ++++++
.../it/partition/IoTDBPartitionCreationIT.java | 130 +++--
.../it/partition/IoTDBPartitionDurableIT.java | 8 +-
.../confignode/it/utils/ConfigNodeTestUtils.java | 4 +-
.../iotdb/db/it/udf/IoTDBUDFManagementIT.java | 50 +-
.../org/apache/iotdb/db/it/utils/TestUtils.java | 84 ++--
.../apache/iotdb/pipe/it/IoTDBPipeDataSyncIT.java | 131 +++++
.../iotdb/pipe/it/IoTDBPipeSingleEnvDemoIT.java | 77 +++
.../iotdb/session/it/IoTDBSessionComplexIT.java | 2 +-
.../main/java/org/apache/iotdb/tool/ImportCsv.java | 2 +-
iotdb-client/client-cpp/pom.xml | 4 +-
iotdb-client/client-py/pom.xml | 2 +-
iotdb-client/service-rpc/pom.xml | 5 -
.../main/java/org/apache/iotdb/rpc/RpcUtils.java | 25 -
.../iotdb/rpc/StatementExecutionException.java | 6 -
iotdb-client/session/pom.xml | 5 +
.../apache/iotdb/session/pool/SessionPoolTest.java | 90 ++--
.../grafana-plugin/pkg/plugin/plugin.go | 2 -
.../resources/conf/iotdb-confignode.properties | 5 +-
.../confignode/client/DataNodeRequestType.java | 3 +-
.../client/async/AsyncDataNodeClientPool.java | 9 +-
.../client/async/handlers/AsyncClientHandler.java | 3 +-
.../confignode/conf/ConfigNodeDescriptor.java | 2 +-
.../manager/consensus/ConsensusManager.java | 11 +
.../iotdb/confignode/manager/load/LoadManager.java | 8 +-
.../manager/load/balancer/RegionBalancer.java | 17 +-
.../manager/load/balancer/RouteBalancer.java | 4 +-
.../region/GreedyRegionGroupAllocator.java | 41 +-
.../load/cache/node/DataNodeHeartbeatCache.java | 4 +-
.../manager/load/cache/region/RegionCache.java | 5 +-
.../load/cache/region/RegionHeartbeatSample.java | 5 +
.../manager/load/service/StatisticsService.java | 18 +-
.../partition/DatabasePartitionTable.java | 4 +-
.../persistence/partition/RegionGroup.java | 11 +
.../confignode/persistence/pipe/PipeTaskInfo.java | 9 +
.../procedure/env/ConfigNodeProcedureEnv.java | 42 +-
.../procedure/env/DataNodeRemoveHandler.java | 7 +-
.../impl/pipe/AbstractOperatePipeProcedureV2.java | 31 +-
.../impl/pipe/task/CreatePipeProcedureV2.java | 9 +-
.../impl/pipe/task/DropPipeProcedureV2.java | 5 +-
.../impl/pipe/task/StartPipeProcedureV2.java | 3 +-
.../impl/pipe/task/StopPipeProcedureV2.java | 3 +-
.../iotdb/confignode/service/ConfigNode.java | 5 +-
.../service/thrift/ConfigNodeRPCService.java | 5 -
.../apache/iotdb/consensus/iot/IoTConsensus.java | 17 +
.../consensus/iot/IoTConsensusServerImpl.java | 8 +
.../iot/client/AsyncIoTConsensusServiceClient.java | 1 +
.../consensus/iot/client/DispatchLogHandler.java | 52 +-
.../consensus/iot/logdispatcher/LogDispatcher.java | 4 +
.../iot/service/IoTConsensusRPCService.java | 8 +-
.../iotdb/consensus/ratis/RatisConsensus.java | 27 +-
.../iotdb/consensus/ratis/SnapshotStorage.java | 2 +-
.../iotdb/consensus/ratis/RatisConsensusTest.java | 4 +-
iotdb-core/datanode/pom.xml | 26 +-
.../resources/conf/iotdb-datanode.properties | 2 +-
.../resources/tools/schema/print-pb-tree-file.sh | 2 +-
.../org/apache/iotdb/db/audit/AuditLogger.java | 2 +-
.../java/org/apache/iotdb/db/conf/IoTDBConfig.java | 24 +-
.../db/consensus/DataRegionConsensusImpl.java | 8 +
.../db/consensus/SchemaRegionConsensusImpl.java | 8 +
.../db/pipe/agent/receiver/PipeReceiverAgent.java | 69 +--
.../db/pipe/agent/runtime/PipeRuntimeAgent.java | 6 +-
.../iotdb/db/pipe/agent/task/PipeTaskAgent.java | 131 +++--
.../config/constant/PipeConnectorConstant.java | 4 +
.../payload/airgap/AirGapOneByteResponse.java | 9 +-
.../airgap/AirGapPseudoTPipeTransferRequest.java | 7 +-
.../{v1 => payload/evolvable}/PipeRequestType.java | 2 +-
.../reponse/PipeTransferFilePieceResp.java | 2 +-
.../request/PipeTransferFilePieceReq.java | 26 +-
.../request/PipeTransferFileSealReq.java | 26 +-
.../request/PipeTransferHandshakeReq.java | 24 +-
.../request/PipeTransferInsertNodeReq.java | 28 +-
.../evolvable}/request/PipeTransferTabletReq.java | 115 ++---
.../legacy}/DeletionPipeData.java | 6 +-
.../pipedata => payload/legacy}/PipeData.java | 4 +-
.../legacy}/TsFilePipeData.java | 6 +-
.../IoTDBConnector.java} | 6 +-
.../IoTDBConnectorRequestVersion.java} | 7 +-
.../protocol/airgap/IoTDBAirGapConnector.java | 350 +++++++++++++
.../legacy/IoTDBLegacyPipeConnector.java} | 22 +-
.../thrift/async/IoTDBThriftAsyncConnector.java} | 49 +-
...nsferInsertNodeTabletInsertionEventHandler.java | 6 +-
...PipeTransferRawTabletInsertionEventHandler.java | 6 +-
.../PipeTransferTabletInsertionEventHandler.java | 11 +-
.../PipeTransferTsFileInsertionEventHandler.java | 14 +-
.../thrift/sync/IoTDBThriftSyncConnector.java} | 74 +--
.../sync/IoTDBThriftSyncConnectorClient.java} | 6 +-
.../tablet/TabletInsertionDataContainer.java | 2 +-
.../pipe/receiver/airgap/IoTDBAirGapReceiver.java | 200 ++++++++
.../receiver/airgap/IoTDBAirGapReceiverAgent.java | 97 ++++
.../legacy/IoTDBLegacyPipeReceiverAgent.java} | 26 +-
.../legacy/loader/DeletionLoader.java | 2 +-
.../legacy/loader/ILoader.java | 2 +-
.../legacy/loader/TsFileLoader.java | 4 +-
.../thrift}/IoTDBThriftReceiver.java | 6 +-
.../thrift/IoTDBThriftReceiverAgent.java} | 37 +-
.../thrift}/IoTDBThriftReceiverV1.java | 38 +-
.../connector/PipeConnectorSubtaskManager.java | 24 +-
.../iotdb/db/protocol/session/SessionManager.java | 8 +-
.../protocol/thrift/impl/ClientRPCServiceImpl.java | 18 +-
.../impl/DataNodeInternalRPCServiceImpl.java | 37 +-
.../thrift/impl/DataNodeRegionManager.java | 10 +
.../queryengine/execution/memory/MemoryPool.java | 13 +-
.../operator/source/AlignedSeriesScanOperator.java | 9 +-
.../operator/source/AlignedSeriesScanUtil.java | 85 +++-
.../db/queryengine/plan/analyze/Analysis.java | 12 +
.../queryengine/plan/analyze/AnalyzeVisitor.java | 398 +--------------
.../plan/analyze/LoadTsfileAnalyzer.java | 543 +++++++++++++++++++++
.../config/executor/ClusterConfigTaskExecutor.java | 9 +-
.../db/queryengine/plan/parser/ASTVisitor.java | 10 +-
.../plan/parser/StatementGenerator.java | 21 +-
.../plan/planner/LogicalPlanBuilder.java | 12 +-
.../plan/planner/LogicalPlanVisitor.java | 6 +-
.../plan/planner/OperatorTreeGenerator.java | 3 +-
.../plan/planner/plan/node/PlanGraphPrinter.java | 1 +
.../plan/node/source/AlignedSeriesScanNode.java | 37 +-
.../scheduler/load/LoadTsFileDispatcherImpl.java | 2 +-
.../plan/statement/crud/LoadTsFileStatement.java | 29 +-
.../plan/statement/crud/QueryStatement.java | 12 +
.../mtree/impl/pbtree/CachedMTreeStore.java | 1 +
.../mtree/impl/pbtree/cache/CacheManager.java | 1 +
.../impl/pbtree/cache/CacheMemoryManager.java | 4 +
.../java/org/apache/iotdb/db/service/DataNode.java | 10 +-
.../db/service/TemporaryQueryDataFileService.java | 2 +-
.../dataregion/HashLastFlushTimeMap.java | 15 +-
.../exception/CompactionExceptionHandler.java | 11 +-
.../execute/task/AbstractCompactionTask.java | 2 +
.../execute/task/CrossSpaceCompactionTask.java | 24 +-
.../execute/task/InnerSpaceCompactionTask.java | 58 ++-
.../compaction/execute/utils/CompactionUtils.java | 53 ++
.../fast/AlignedSeriesCompactionExecutor.java | 28 +-
.../execute/utils/log/CompactionLogAnalyzer.java | 16 +-
.../estimator/AbstractCompactionEstimator.java | 3 +-
.../estimator/AbstractInnerSpaceEstimator.java | 74 ++-
.../estimator/CompactionEstimateUtils.java | 96 ++++
.../FastCompactionInnerCompactionEstimator.java | 52 ++
.../compaction/selector/estimator/FileInfo.java | 48 ++
.../ReadChunkInnerCompactionEstimator.java | 59 +++
.../ReadPointCrossCompactionEstimator.java | 81 +--
.../memtable/AlignedReadOnlyMemChunk.java | 12 +-
.../dataregion/memtable/TsFileProcessor.java | 146 +++---
.../read/reader/chunk/DiskAlignedChunkLoader.java | 13 +-
.../read/reader/chunk/MemAlignedChunkLoader.java | 11 +-
.../read/reader/chunk/MemAlignedChunkReader.java | 8 +-
.../read/reader/chunk/MemAlignedPageReader.java | 41 +-
.../metadata/DiskAlignedChunkMetadataLoader.java | 16 +-
.../metadata/MemAlignedChunkMetadataLoader.java | 19 +-
.../dataregion/tsfile/TsFileManager.java | 17 +
.../wal/checkpoint/CheckpointManager.java | 2 +-
.../storageengine/dataregion/wal/node/WALNode.java | 243 ++++++---
.../org/apache/iotdb/db/utils/CommonUtils.java | 43 --
.../org/apache/iotdb/db/utils/FileLoaderUtils.java | 42 +-
.../db/utils/datastructure/AlignedTVList.java | 46 ++
.../iotdb/db/pipe/connector/PipeConnectorTest.java | 24 +-
.../iotdb/db/pipe/connector/PipeReceiverTest.java | 6 +-
.../db/pipe/connector/PipeThriftRequestTest.java | 12 +-
.../operator/AlignedSeriesScanOperatorTest.java | 15 +-
.../execution/operator/OperatorMemoryTest.java | 3 +-
.../plan/plan/QueryLogicalPlanUtil.java | 5 +-
.../compaction/CompactionSchedulerTest.java | 1 +
.../inner/InnerSpaceCompactionExceptionTest.java | 4 +-
.../utils/CompactionTaskMemCostEstimatorTest.java | 94 ++++
.../dataregion/memtable/TsFileProcessorTest.java | 97 ++++
.../reader/chunk/MemAlignedChunkLoaderTest.java | 2 +-
iotdb-core/mlnode/pom.xml | 2 +-
iotdb-core/node-commons/pom.xml | 5 -
.../resources/conf/iotdb-common.properties | 86 +---
.../src/assembly/resources/sbin/iotdb-common.sh | 15 +-
.../iotdb/commons/client/ClientPoolFactory.java | 2 +-
.../async/AsyncConfigNodeIServiceClient.java | 1 +
.../async/AsyncDataNodeInternalServiceClient.java | 1 +
.../AsyncDataNodeMPPDataExchangeServiceClient.java | 1 +
.../async/AsyncPipeDataTransferServiceClient.java | 1 +
.../iotdb/commons/concurrent/ThreadName.java | 11 +-
.../WrappedScheduledExecutorService.java | 2 +-
.../WrappedSingleThreadExecutorService.java | 2 +-
.../WrappedSingleThreadScheduledExecutor.java | 2 +-
.../threadpool/WrappedThreadPoolExecutor.java | 4 +-
.../apache/iotdb/commons/conf/CommonConfig.java | 42 +-
.../iotdb/commons/conf/CommonDescriptor.java | 19 +-
.../apache/iotdb/commons/conf/IoTDBConstant.java | 4 +-
.../commons/executable/ExecutableManager.java | 11 +-
.../org/apache/iotdb/commons/path/PartialPath.java | 158 ++++--
.../iotdb/commons/path/PathPatternTreeUtils.java | 53 ++
.../apache/iotdb/commons/path/PathPatternUtil.java | 4 +-
.../iotdb/commons/path/fa/dfa/graph/NFAGraph.java | 2 +-
.../iotdb/commons/pipe/config/PipeConfig.java | 24 +-
.../pipe/plugin/builtin/BuiltinPipePlugin.java | 14 +-
...tConnectorV1.java => IoTDBAirGapConnector.java} | 10 +-
...nectorV1.java => IoTDBLegacyPipeConnector.java} | 10 +-
...ectorV1.java => IoTDBThriftAsyncConnector.java} | 10 +-
.../builtin/connector/IoTDBThriftConnector.java | 54 +-
...nectorV2.java => IoTDBThriftSyncConnector.java} | 10 +-
...yncConnector.java => PlaceholderConnector.java} | 12 +-
.../commons/pipe/task/meta/PipeMetaKeeper.java | 4 +
.../apache/iotdb/commons/service/ServiceType.java | 6 +-
.../iotdb/commons/service/ThriftService.java | 3 +-
.../commons/service/metric/MetricService.java | 3 +-
.../iotdb/commons/client/ClientManagerTest.java | 128 ++++-
.../client/mock/MockInternalRPCService.java | 4 -
.../apache/iotdb/commons/path/PartialPathTest.java | 68 +++
.../iotdb/commons/path/PathPatternTreeTest.java | 121 +++++
.../pipe/plugin/builtin/BuiltinPipePluginTest.java | 4 +-
.../read/TsFileAlignedSeriesReaderIterator.java | 2 +-
.../iotdb/tsfile/read/TsFileSequenceReader.java | 12 +-
.../read/reader/chunk/AlignedChunkReader.java | 22 +-
.../tsfile/read/reader/page/AlignedPageReader.java | 41 +-
.../read/reader/series/FileSeriesReader.java | 2 +-
.../org/apache/iotdb/tsfile/utils/BytesUtils.java | 4 +-
.../org/apache/iotdb/tsfile/utils/PublicBAOS.java | 1 +
.../tsfile/write/TsFileIntegrityCheckingTool.java | 3 +-
iotdb-protocol/pom.xml | 2 +-
.../{thrift => thrift-datanode}/README.md | 0
iotdb-protocol/{thrift => thrift-datanode}/pom.xml | 4 +-
.../{thrift => thrift-datanode}/rpc-changelist.md | 0
.../src/main/thrift/client.thrift | 0
.../src/main/thrift/datanode.thrift | 10 +
pom.xml | 43 +-
266 files changed, 6123 insertions(+), 2489 deletions(-)
create mode 100644 .github/workflows/pipe-it-2cluster.yml
copy integration-test/src/main/java/org/apache/iotdb/it/env/{EnvFactory.java
=> MultiEnvFactory.java} (57%)
create mode 100644
integration-test/src/main/java/org/apache/iotdb/it/env/cluster/ClusterConstant.java
delete mode 100644
integration-test/src/main/java/org/apache/iotdb/it/env/cluster/ConfigNodeWrapper.java
delete mode 100644
integration-test/src/main/java/org/apache/iotdb/it/env/cluster/DataNodeWrapper.java
rename integration-test/src/main/java/org/apache/iotdb/it/env/cluster/{ =>
config}/MppBaseConfig.java (97%)
rename integration-test/src/main/java/org/apache/iotdb/it/env/cluster/{ =>
config}/MppClusterConfig.java (98%)
rename integration-test/src/main/java/org/apache/iotdb/it/env/cluster/{ =>
config}/MppCommonConfig.java (88%)
rename integration-test/src/main/java/org/apache/iotdb/it/env/cluster/{ =>
config}/MppConfigNodeConfig.java (97%)
rename integration-test/src/main/java/org/apache/iotdb/it/env/cluster/{ =>
config}/MppDataNodeConfig.java (97%)
rename integration-test/src/main/java/org/apache/iotdb/it/env/cluster/{ =>
config}/MppJVMConfig.java (98%)
rename integration-test/src/main/java/org/apache/iotdb/it/env/cluster/{ =>
config}/MppSharedCommonConfig.java (97%)
rename integration-test/src/main/java/org/apache/iotdb/it/env/cluster/{ =>
env}/AbstractEnv.java (90%)
copy integration-test/src/main/java/org/apache/iotdb/it/env/cluster/{ =>
env}/Cluster1Env.java (92%)
rename
integration-test/src/main/java/org/apache/iotdb/it/env/cluster/{Cluster1Env.java
=> env/MultiClusterEnv.java} (74%)
rename integration-test/src/main/java/org/apache/iotdb/it/env/cluster/{ =>
env}/SimpleEnv.java (96%)
rename integration-test/src/main/java/org/apache/iotdb/it/env/cluster/{ =>
node}/AbstractNodeWrapper.java (52%)
create mode 100644
integration-test/src/main/java/org/apache/iotdb/it/env/cluster/node/ConfigNodeWrapper.java
create mode 100644
integration-test/src/main/java/org/apache/iotdb/it/env/cluster/node/DataNodeWrapper.java
rename integration-test/src/main/java/org/apache/iotdb/it/env/remote/{ =>
config}/RemoteClusterConfig.java (97%)
rename integration-test/src/main/java/org/apache/iotdb/it/env/remote/{ =>
config}/RemoteCommonConfig.java (97%)
copy integration-test/src/main/java/org/apache/iotdb/it/env/remote/{ =>
config}/RemoteConfigNodeConfig.java (95%)
copy integration-test/src/main/java/org/apache/iotdb/it/env/remote/{ =>
config}/RemoteDataNodeConfig.java (95%)
rename integration-test/src/main/java/org/apache/iotdb/it/env/remote/{ =>
config}/RemoteJVMConfig.java (96%)
rename integration-test/src/main/java/org/apache/iotdb/it/env/remote/{ =>
env}/RemoteServerEnv.java (97%)
copy
integration-test/src/main/java/org/apache/iotdb/{it/env/remote/RemoteDataNodeConfig.java
=> itbase/category/MultiClusterIT1.java} (84%)
copy
integration-test/src/main/java/org/apache/iotdb/{it/env/remote/RemoteDataNodeConfig.java
=> itbase/category/MultiClusterIT2.java} (84%)
rename
integration-test/src/main/java/org/apache/iotdb/{it/env/remote/RemoteDataNodeConfig.java
=> itbase/category/MultiClusterIT3.java} (84%)
create mode 100644
integration-test/src/test/java/org/apache/iotdb/confignode/it/partition/IoTDBAutoRegionGroupExtensionIT2.java
create mode 100644
integration-test/src/test/java/org/apache/iotdb/pipe/it/IoTDBPipeDataSyncIT.java
create mode 100644
integration-test/src/test/java/org/apache/iotdb/pipe/it/IoTDBPipeSingleEnvDemoIT.java
copy
integration-test/src/main/java/org/apache/iotdb/it/env/remote/RemoteConfigNodeConfig.java
=>
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/connector/payload/airgap/AirGapOneByteResponse.java
(79%)
rename
integration-test/src/main/java/org/apache/iotdb/it/env/remote/RemoteConfigNodeConfig.java
=>
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/connector/payload/airgap/AirGapPseudoTPipeTransferRequest.java
(80%)
rename
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/connector/{v1 =>
payload/evolvable}/PipeRequestType.java (96%)
rename
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/connector/{v1 =>
payload/evolvable}/reponse/PipeTransferFilePieceResp.java (97%)
rename
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/connector/{v1 =>
payload/evolvable}/request/PipeTransferFilePieceReq.java (74%)
rename
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/connector/{v1 =>
payload/evolvable}/request/PipeTransferFileSealReq.java (73%)
rename
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/connector/{v1 =>
payload/evolvable}/request/PipeTransferHandshakeReq.java (73%)
rename
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/connector/{v1 =>
payload/evolvable}/request/PipeTransferInsertNodeReq.java (77%)
rename
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/connector/{v1 =>
payload/evolvable}/request/PipeTransferTabletReq.java (88%)
rename
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/connector/{legacy/pipedata
=> payload/legacy}/DeletionPipeData.java (93%)
rename
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/connector/{legacy/pipedata
=> payload/legacy}/PipeData.java (96%)
rename
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/connector/{legacy/pipedata
=> payload/legacy}/TsFilePipeData.java (95%)
rename
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/connector/{base/IoTDBThriftConnector.java
=> protocol/IoTDBConnector.java} (95%)
rename
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/connector/{IoTDBThriftConnectorRequestVersion.java
=> protocol/IoTDBConnectorRequestVersion.java} (85%)
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/connector/protocol/airgap/IoTDBAirGapConnector.java
rename
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/connector/{legacy/IoTDBSyncConnector.java
=> protocol/legacy/IoTDBLegacyPipeConnector.java} (93%)
rename
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/connector/{v2/IoTDBThriftConnectorV2.java
=> protocol/thrift/async/IoTDBThriftAsyncConnector.java} (90%)
rename
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/connector/{v2 =>
protocol/thrift/async}/handler/PipeTransferInsertNodeTabletInsertionEventHandler.java
(88%)
rename
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/connector/{v2 =>
protocol/thrift/async}/handler/PipeTransferRawTabletInsertionEventHandler.java
(88%)
rename
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/connector/{v2 =>
protocol/thrift/async}/handler/PipeTransferTabletInsertionEventHandler.java
(90%)
rename
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/connector/{v2 =>
protocol/thrift/async}/handler/PipeTransferTsFileInsertionEventHandler.java
(91%)
rename
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/connector/{v1/IoTDBThriftConnectorV1.java
=> protocol/thrift/sync/IoTDBThriftSyncConnector.java} (82%)
rename
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/connector/{v1/IoTDBThriftConnectorClient.java
=> protocol/thrift/sync/IoTDBThriftSyncConnectorClient.java} (90%)
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/receiver/airgap/IoTDBAirGapReceiver.java
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/receiver/airgap/IoTDBAirGapReceiverAgent.java
rename
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/{connector/legacy/IoTDBSyncReceiver.java
=> receiver/legacy/IoTDBLegacyPipeReceiverAgent.java} (95%)
rename iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/{connector
=> receiver}/legacy/loader/DeletionLoader.java (98%)
rename iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/{connector
=> receiver}/legacy/loader/ILoader.java (96%)
rename iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/{connector
=> receiver}/legacy/loader/TsFileLoader.java (96%)
rename
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/{agent/receiver =>
receiver/thrift}/IoTDBThriftReceiver.java (87%)
copy
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/{agent/receiver/PipeReceiverAgent.java
=> receiver/thrift/IoTDBThriftReceiverAgent.java} (70%)
rename
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/{connector/v1 =>
receiver/thrift}/IoTDBThriftReceiverV1.java (92%)
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/analyze/LoadTsfileAnalyzer.java
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/storageengine/dataregion/compaction/selector/estimator/CompactionEstimateUtils.java
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/storageengine/dataregion/compaction/selector/estimator/FastCompactionInnerCompactionEstimator.java
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/storageengine/dataregion/compaction/selector/estimator/FileInfo.java
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/storageengine/dataregion/compaction/selector/estimator/ReadChunkInnerCompactionEstimator.java
create mode 100644
iotdb-core/datanode/src/test/java/org/apache/iotdb/db/storageengine/dataregion/compaction/utils/CompactionTaskMemCostEstimatorTest.java
create mode 100644
iotdb-core/node-commons/src/main/java/org/apache/iotdb/commons/path/PathPatternTreeUtils.java
copy
iotdb-core/node-commons/src/main/java/org/apache/iotdb/commons/pipe/plugin/builtin/connector/{IoTDBThriftConnectorV1.java
=> IoTDBAirGapConnector.java} (73%)
copy
iotdb-core/node-commons/src/main/java/org/apache/iotdb/commons/pipe/plugin/builtin/connector/{IoTDBThriftConnectorV1.java
=> IoTDBLegacyPipeConnector.java} (72%)
rename
iotdb-core/node-commons/src/main/java/org/apache/iotdb/commons/pipe/plugin/builtin/connector/{IoTDBThriftConnectorV1.java
=> IoTDBThriftAsyncConnector.java} (73%)
rename
iotdb-core/node-commons/src/main/java/org/apache/iotdb/commons/pipe/plugin/builtin/connector/{IoTDBThriftConnectorV2.java
=> IoTDBThriftSyncConnector.java} (73%)
rename
iotdb-core/node-commons/src/main/java/org/apache/iotdb/commons/pipe/plugin/builtin/connector/{IoTDBSyncConnector.java
=> PlaceholderConnector.java} (86%)
rename iotdb-protocol/{thrift => thrift-datanode}/README.md (100%)
rename iotdb-protocol/{thrift => thrift-datanode}/pom.xml (96%)
rename iotdb-protocol/{thrift => thrift-datanode}/rpc-changelist.md (100%)
rename iotdb-protocol/{thrift =>
thrift-datanode}/src/main/thrift/client.thrift (100%)
rename iotdb-protocol/{thrift =>
thrift-datanode}/src/main/thrift/datanode.thrift (98%)
