This is an automated email from the ASF dual-hosted git repository.
jiangtian pushed a change to branch strong_password
in repository https://gitbox.apache.org/repos/asf/iotdb.git
from 5c8c9ad5b2a Merge remote-tracking branch 'origin/master' into
strong_password
add 004b1bff0f4 Set global time filter before analyze last query
add 441f85183a4 [AINode] Update AINode wrapper (#16028)
add 5b3cd27d5e2 Load: Added the missing logic for tsFile conversion
disable's cherry-picking (#16024)
add 52d34557b0d Fix negative iot queue size & missing search index for
deletion & missed request when performing empty table deleting (#16022)
add 08bdb45e2ce Refined the debug logger of partition cache
add fb3a69ceeed Pipe: Banned the useless IT for table conversion (#16038)
add 8a79fa3b446 Load: Fix the Session exit issue after type conversion
(#16037)
add 2a8192a428d Pipe: Simplified the hybrid down-grading logic (#16033)
add 253434481f0 Pipe IT & Subscription IT: migrate workflows that are not
in HighPerformanceMode to daily IT (#15971)
add f3e22205ce2 [AINode] Adding scheduler to support concurrent inference
(#16005)
add 9a6d3f5c7d3 Pipe: Change the name of the Extractor plugin to Source
&&Change the name of the Connector plugin to Sink (#16034)
add a4cadf75957 Pipe: Optimized the floating memory calculation & Fixed
potential NPE in insertRows privilege checking (#16039)
add 3342b5f8362 Merge branch 'master' into strong_password
No new revisions were added by this update.
Summary of changes:
.github/workflows/daily-it.yml | 902 ++++++++++++++++++++-
.github/workflows/pipe-it.yml | 87 +-
.../iotdb/it/env/cluster/node/AINodeWrapper.java | 8 +-
.../iotdb/ainode/it/AINodeInferenceSQLIT.java | 2 +-
...IoTDBRegionOperationReliabilityITFramework.java | 9 +-
.../IoTDBRegionMigrateWithLastEmptyDeletionIT.java | 101 +++
.../manual/basic/IoTDBPipePermissionIT.java | 2 +-
...PipeExtractorIT.java => IoTDBPipeSourceIT.java} | 2 +-
...sionIT.java => IoTDBPipeSinkCompressionIT.java} | 2 +-
...arallelIT.java => IoTDBPipeSinkParallelIT.java} | 2 +-
.../IoTDBPipeTypeConversionISessionIT.java | 2 +
...arallelIT.java => IoTDBPipeSinkParallelIT.java} | 2 +-
...PipeExtractorIT.java => IoTDBPipeSourceIT.java} | 2 +-
...sionIT.java => IoTDBPipeSinkCompressionIT.java} | 2 +-
.../relational/it/schema/IoTDBDatabaseIT.java | 4 +-
.../iotdb/tool/tsfile/ImportTsFileRemotely.java | 20 +-
.../core/inference/inference_request_pool.py | 123 ++-
.../ainode/core/inference/scheduler}/__init__.py | 0
.../core/inference/scheduler/abstract_scheduler.py | 62 ++
.../core/inference/scheduler/basic_scheduler.py | 87 ++
.../response/pipe/task/PipeTableResp.java | 2 +-
.../iotdb/confignode/manager/ConfigManager.java | 2 +-
.../agent/plugin/PipeConfigNodePluginAgent.java | 12 +-
...r.java => PipeConfigRegionSinkConstructor.java} | 42 +-
...java => PipeConfigRegionSourceConstructor.java} | 19 +-
.../receiver/IoTDBConfigNodeReceiverAgent.java | 4 +-
.../agent/runtime/PipeConfigNodeRuntimeAgent.java | 2 +-
.../agent/runtime/PipeConfigRegionListener.java | 4 +-
.../pipe/agent/task/PipeConfigNodeSubtask.java | 21 +-
.../pipe/agent/task/PipeConfigNodeTaskAgent.java | 6 +-
.../pipe/agent/task/PipeConfigNodeTaskBuilder.java | 2 +-
.../runtime/heartbeat/PipeHeartbeatParser.java | 4 +-
.../manager/pipe/metric/PipeConfigNodeMetrics.java | 12 +-
.../PipeConfigNodeRemainingTimeMetrics.java | 4 +-
.../PipeConfigNodeRemainingTimeOperator.java | 8 +-
...trics.java => PipeConfigRegionSinkMetrics.java} | 12 +-
.../source/PipeConfigNodeListenerMetrics.java | 2 +-
...ics.java => PipeConfigRegionSourceMetrics.java} | 27 +-
.../receiver/protocol/IoTDBConfigNodeReceiver.java | 26 +-
.../client/IoTDBConfigNodeSyncClientManager.java | 10 +-
.../PipeTransferConfigNodeHandshakeV1Req.java | 6 +-
.../PipeTransferConfigNodeHandshakeV2Req.java | 6 +-
.../payload/PipeTransferConfigPlanReq.java | 10 +-
.../PipeTransferConfigSnapshotPieceReq.java | 6 +-
.../payload/PipeTransferConfigSnapshotSealReq.java | 6 +-
.../protocol/IoTDBConfigRegionAirGapSink.java} | 29 +-
.../protocol/IoTDBConfigRegionSink.java} | 30 +-
.../ConfigRegionListeningFilter.java | 2 +-
.../ConfigRegionListeningQueue.java | 2 +-
.../IoTDBConfigRegionSource.java} | 12 +-
...ConfigPhysicalPlanTablePatternParseVisitor.java | 2 +-
...nfigPhysicalPlanTablePrivilegeParseVisitor.java | 2 +-
...peConfigPhysicalPlanTableScopeParseVisitor.java | 2 +-
...eConfigPhysicalPlanTreePatternParseVisitor.java | 2 +-
...ipeConfigPhysicalPlanTreeScopeParseVisitor.java | 2 +-
.../persistence/pipe/PipePluginInfo.java | 8 +-
.../confignode/persistence/pipe/PipeTaskInfo.java | 8 +-
.../impl/pipe/AbstractOperatePipeProcedureV2.java | 2 +-
.../impl/pipe/runtime/PipeMetaSyncProcedure.java | 15 +-
.../impl/pipe/task/AlterPipeProcedureV2.java | 20 +-
.../impl/pipe/task/CreatePipeProcedureV2.java | 70 +-
.../pipe/util/PipeExternalSourceLoadBalancer.java | 10 +-
.../response/pipe/PipePluginTableRespTest.java | 4 +-
.../agent/PipeConfigNodeSubtaskExecutorTest.java | 4 +-
.../IoTDBConfigRegionSinkTest.java} | 16 +-
.../PipeConfigNodeThriftRequestTest.java | 10 +-
.../IoTDBConfigRegionSourceTest.java} | 22 +-
...ipeConfigPhysicalPlanScopeParseVisitorTest.java | 6 +-
...igPhysicalPlanTablePatternParseVisitorTest.java | 8 +-
...figPhysicalPlanTreePatternParseVisitorTest.java | 44 +-
.../common/request/IndexedConsensusRequest.java | 10 +
.../logdispatcher/IoTConsensusMemoryManager.java | 21 +
.../consensus/iot/logdispatcher/LogDispatcher.java | 22 +-
.../pipe/consensuspipe/ConsensusPipeManager.java | 32 +-
...usPipeConnector.java => ConsensusPipeSink.java} | 2 +-
.../pipe/metric/PipeConsensusSyncLagManager.java | 21 +-
.../org/apache/iotdb/db/auth/AuthorityChecker.java | 2 +-
.../schemaregion/SchemaExecutionVisitor.java | 2 +-
.../schemaregion/SchemaRegionStateMachine.java | 2 +-
.../dataregion/PipeDataRegionPluginAgent.java | 14 +-
...tor.java => PipeDataRegionSinkConstructor.java} | 83 +-
...r.java => PipeDataRegionSourceConstructor.java} | 25 +-
.../schemaregion/PipeSchemaRegionPluginAgent.java | 12 +-
...r.java => PipeSchemaRegionSinkConstructor.java} | 42 +-
...java => PipeSchemaRegionSourceConstructor.java} | 19 +-
.../db/pipe/agent/runtime/PipeAgentLauncher.java | 2 +-
.../agent/runtime/PipeDataNodeRuntimeAgent.java | 2 +-
.../runtime/PipeSchemaRegionListenerManager.java | 2 +-
.../db/pipe/agent/task/PipeDataNodeTaskAgent.java | 112 ++-
.../agent/task/builder/PipeDataNodeBuilder.java | 4 +-
.../task/builder/PipeDataNodeTaskBuilder.java | 73 +-
.../agent/task/connection/PipeEventCollector.java | 8 +-
...kExecutor.java => PipeSinkSubtaskExecutor.java} | 6 +-
.../task/execution/PipeSubtaskExecutorManager.java | 6 +-
...kConnectorStage.java => PipeTaskSinkStage.java} | 26 +-
...xtractorStage.java => PipeTaskSourceStage.java} | 6 +-
.../PipeRealtimePriorityBlockingQueue.java | 2 +-
.../PipeSinkSubtask.java} | 64 +-
.../PipeSinkSubtaskLifeCycle.java} | 37 +-
.../PipeSinkSubtaskManager.java} | 70 +-
.../consensus/PipeConsensusSubtaskExecutor.java | 4 +-
...rMetrics.java => PipeConsensusSinkMetrics.java} | 12 +-
.../tablet/PipeInsertNodeTabletInsertionEvent.java | 71 +-
.../tsfile/PipeCompactedTsFileInsertionEvent.java | 2 +-
.../common/tsfile/PipeTsFileInsertionEvent.java | 2 +-
.../db/pipe/event/realtime/PipeRealtimeEvent.java | 6 +-
.../event/realtime/PipeRealtimeEventFactory.java | 21 +-
.../PipeRealtimeDataRegionHybridExtractor.java | 457 -----------
.../iotdb/db/pipe/metric/PipeDataNodeMetrics.java | 24 +-
.../PipeDataNodeRemainingEventAndTimeOperator.java | 12 +-
.../overview/PipeDataNodeSinglePipeMetrics.java | 8 +-
.../overview/PipeTsFileToTabletsMetrics.java | 4 +-
.../schema/PipeSchemaRegionListenerMetrics.java | 2 +-
...trics.java => PipeSchemaRegionSinkMetrics.java} | 33 +-
...ics.java => PipeSchemaRegionSourceMetrics.java} | 25 +-
...Metrics.java => PipeDataRegionSinkMetrics.java} | 56 +-
.../db/pipe/metric/source/PipeAssignerMetrics.java | 2 +-
...trics.java => PipeDataRegionSourceMetrics.java} | 48 +-
.../twostage/exchange/payload/CombineRequest.java | 4 +-
.../payload/FetchCombineResultRequest.java | 4 +-
.../receiver/TwoStageAggregateReceiver.java | 6 +-
.../exchange/sender/TwoStageAggregateSender.java | 2 +-
.../protocol/airgap/IoTDBAirGapReceiver.java | 6 +-
.../legacy/IoTDBLegacyPipeReceiverAgent.java | 4 +-
.../pipeconsensus/PipeConsensusReceiver.java | 22 +-
.../pipeconsensus/PipeConsensusReceiverAgent.java | 2 +-
.../protocol/thrift/IoTDBDataNodeReceiver.java | 48 +-
.../thrift/IoTDBDataNodeReceiverAgent.java | 6 +-
...leStatementDataTypeConvertExecutionVisitor.java | 2 +-
...eeStatementDataTypeConvertExecutionVisitor.java | 2 +-
.../resource/tsfile/PipeCompactionManager.java | 16 +-
.../client/IoTDBDataNodeAsyncClientManager.java | 16 +-
.../IoTDBDataNodeCacheLeaderClientManager.java | 2 +-
.../client/IoTDBDataNodeSyncClientManager.java | 12 +-
.../evolvable/batch/PipeTabletEventBatch.java | 6 +-
.../evolvable/batch/PipeTabletEventPlainBatch.java | 10 +-
.../batch/PipeTabletEventTsFileBatch.java | 18 +-
.../batch/PipeTransferBatchReqBuilder.java | 38 +-
.../PipeTransferDataNodeHandshakeV1Req.java | 6 +-
.../PipeTransferDataNodeHandshakeV2Req.java | 6 +-
.../evolvable/request/PipeTransferPlanNodeReq.java | 10 +-
.../PipeTransferSchemaSnapshotPieceReq.java | 6 +-
.../request/PipeTransferSchemaSnapshotSealReq.java | 6 +-
.../request/PipeTransferTabletBatchReq.java | 8 +-
.../request/PipeTransferTabletBatchReqV2.java | 8 +-
.../request/PipeTransferTabletBinaryReq.java | 10 +-
.../request/PipeTransferTabletBinaryReqV2.java | 12 +-
.../request/PipeTransferTabletInsertNodeReq.java | 12 +-
.../request/PipeTransferTabletInsertNodeReqV2.java | 12 +-
.../request/PipeTransferTabletRawReq.java | 12 +-
.../request/PipeTransferTabletRawReqV2.java | 16 +-
.../request/PipeTransferTsFilePieceReq.java | 6 +-
.../request/PipeTransferTsFilePieceWithModReq.java | 6 +-
.../request/PipeTransferTsFileSealReq.java | 6 +-
.../request/PipeTransferTsFileSealWithModReq.java | 6 +-
.../payload/legacy/DeletionPipeData.java | 2 +-
.../payload/legacy/PipeData.java | 2 +-
.../payload/legacy/TsFilePipeData.java | 2 +-
.../protocol/airgap/IoTDBDataNodeAirGapSink.java} | 12 +-
.../airgap/IoTDBDataRegionAirGapSink.java} | 50 +-
.../airgap/IoTDBSchemaRegionAirGapSink.java} | 21 +-
.../protocol/legacy/IoTDBLegacyPipeSink.java} | 62 +-
.../protocol/opcda/OpcDaHeader.java | 2 +-
.../protocol/opcda/OpcDaServerHandle.java | 12 +-
.../protocol/opcda/OpcDaSink.java} | 18 +-
.../protocol/opcua/OpcUaKeyStoreLoader.java | 2 +-
.../protocol/opcua/OpcUaNameSpace.java | 6 +-
.../protocol/opcua/OpcUaServerBuilder.java | 17 +-
.../protocol/opcua/OpcUaSink.java} | 72 +-
.../pipeconsensus/PipeConsensusAsyncSink.java} | 108 ++-
.../pipeconsensus/PipeConsensusSyncSink.java} | 66 +-
.../handler/PipeConsensusDeleteEventHandler.java | 14 +-
.../PipeConsensusTabletBatchEventHandler.java | 20 +-
.../PipeConsensusTabletInsertNodeEventHandler.java | 10 +-
.../PipeConsensusTabletInsertionEventHandler.java | 16 +-
.../PipeConsensusTsFileInsertionEventHandler.java | 24 +-
.../builder/PipeConsensusAsyncBatchReqBuilder.java | 2 +-
.../builder/PipeConsensusSyncBatchReqBuilder.java | 2 +-
.../PipeConsensusTransferBatchReqBuilder.java | 24 +-
.../request/PipeConsensusDeleteNodeReq.java | 6 +-
.../request/PipeConsensusTabletBatchReq.java | 2 +-
.../request/PipeConsensusTabletBinaryReq.java | 6 +-
.../request/PipeConsensusTabletInsertNodeReq.java | 6 +-
.../request/PipeConsensusTsFilePieceReq.java | 6 +-
.../PipeConsensusTsFilePieceWithModReq.java | 6 +-
.../request/PipeConsensusTsFileSealReq.java | 6 +-
.../request/PipeConsensusTsFileSealWithModReq.java | 6 +-
.../thrift/async/IoTDBDataRegionAsyncSink.java} | 103 ++-
.../PipeTransferTabletBatchEventHandler.java | 10 +-
.../PipeTransferTabletInsertNodeEventHandler.java | 6 +-
.../PipeTransferTabletInsertionEventHandler.java | 6 +-
.../handler/PipeTransferTabletRawEventHandler.java | 6 +-
.../handler/PipeTransferTrackableHandler.java | 8 +-
.../async/handler/PipeTransferTsFileHandler.java | 18 +-
.../thrift/sync/IoTDBDataNodeSyncSink.java} | 10 +-
.../thrift/sync/IoTDBDataRegionSyncSink.java} | 68 +-
.../thrift/sync/IoTDBSchemaRegionSink.java} | 24 +-
.../websocket/WebSocketConnectorServer.java | 18 +-
.../protocol/websocket/WebSocketSink.java} | 18 +-
.../protocol/writeback/WriteBackSink.java} | 51 +-
.../util/builder/PipeTableModelTsFileBuilder.java | 2 +-
.../builder/PipeTableModelTsFileBuilderV2.java | 2 +-
.../util/builder/PipeTreeModelTsFileBuilder.java | 2 +-
.../util/builder/PipeTreeModelTsFileBuilderV2.java | 2 +-
.../util/builder/PipeTsFileBuilder.java | 2 +-
.../util/cacher/LeaderCacheUtils.java | 2 +-
.../sorter/PipeTableModelTabletEventSorter.java | 2 +-
.../util/sorter/PipeTabletEventSorter.java | 2 +-
.../sorter/PipeTreeModelTabletEventSorter.java | 2 +-
.../dataregion/DataRegionListeningFilter.java | 2 +-
.../dataregion/DataRegionWatermarkInjector.java | 2 +-
.../dataregion/IoTDBDataRegionSource.java} | 205 +++--
.../PipeHistoricalDataRegionSource.java} | 4 +-
...storicalDataRegionTsFileAndDeletionSource.java} | 88 +-
.../PipeRealtimeDataRegionHeartbeatSource.java} | 8 +-
.../PipeRealtimeDataRegionHybridSource.java | 304 +++++++
.../realtime/PipeRealtimeDataRegionLogSource.java} | 19 +-
.../realtime/PipeRealtimeDataRegionSource.java} | 91 +--
.../PipeRealtimeDataRegionTsFileSource.java} | 18 +-
.../realtime/assigner/DisruptorQueue.java | 2 +-
.../assigner/DisruptorQueueExceptionHandler.java | 2 +-
.../realtime/assigner/PipeDataRegionAssigner.java | 14 +-
.../PipeTsFileEpochProgressIndexKeeper.java | 2 +-
.../dataregion/realtime/epoch/TsFileEpoch.java | 14 +-
.../realtime/epoch/TsFileEpochManager.java | 2 +-
.../realtime/epoch/TsFileEpochStateMigrator.java | 2 +-
.../listener/PipeInsertionDataNodeListener.java | 10 +-
.../listener/PipeTimePartitionListener.java | 15 +-
.../matcher/CachedSchemaPatternMatcher.java | 48 +-
.../realtime/matcher/PipeDataRegionMatcher.java | 10 +-
.../mqtt/MQTTPublishHandler.java | 8 +-
.../mqtt/MQTTSource.java} | 48 +-
.../schemaregion/IoTDBSchemaRegionSource.java} | 12 +-
.../PipePlanTablePatternParseVisitor.java | 2 +-
.../PipePlanTablePrivilegeParseVisitor.java | 2 +-
.../PipePlanTreePatternParseVisitor.java | 2 +-
.../schemaregion/PipeStatementToPlanVisitor.java | 2 +-
.../schemaregion/SchemaRegionListeningFilter.java | 2 +-
.../schemaregion/SchemaRegionListeningQueue.java | 2 +-
.../iotdb/db/protocol/session/SessionManager.java | 10 +
.../queryengine/plan/analyze/AnalyzeVisitor.java | 1 +
.../analyze/cache/partition/PartitionCache.java | 86 +-
.../analyze/load/LoadTsFileTableSchemaCache.java | 17 +-
.../load/TreeSchemaAutoCreatorAndVerifier.java | 30 +-
.../execution/config/TableConfigTaskVisitor.java | 55 +-
.../config/executor/ClusterConfigTaskExecutor.java | 33 +-
.../execution/config/sys/pipe/AlterPipeTask.java | 18 +-
.../execution/config/sys/pipe/CreatePipeTask.java | 18 +-
.../config/sys/pipe/PipeFunctionSupport.java | 4 +-
.../plan/node/pipe/PipeEnrichedInsertNode.java | 4 +-
.../plan/node/pipe/PipeOperateSchemaQueueNode.java | 2 +-
.../planner/plan/node/write/DeleteDataNode.java | 9 +-
.../plan/node/write/InsertMultiTabletsNode.java | 3 +-
.../planner/plan/node/write/InsertRowsNode.java | 3 +-
.../plan/node/write/InsertRowsOfOneDeviceNode.java | 3 +-
.../plan/node/write/RelationalDeleteDataNode.java | 9 +-
.../plan/planner/plan/node/write/SearchNode.java | 3 +-
.../db/storageengine/dataregion/DataRegion.java | 14 +-
.../dataregion/memtable/TsFileProcessor.java | 2 +-
...leStatementDataTypeConvertExecutionVisitor.java | 2 +-
...eeStatementDataTypeConvertExecutionVisitor.java | 2 +-
.../converter/LoadTsFileDataTypeConverter.java | 81 +-
.../load/limiter/LoadTsFileRateLimiter.java | 2 +-
.../rescon/memory/TimePartitionManager.java | 2 +-
.../agent/SubscriptionBrokerAgent.java | 4 +-
.../batch/SubscriptionPipeTsFileEventBatch.java | 2 +-
.../execution/SubscriptionSubtaskExecutor.java | 4 +-
...orStage.java => SubscriptionTaskSinkStage.java} | 26 +-
...orSubtask.java => SubscriptionSinkSubtask.java} | 8 +-
....java => SubscriptionSinkSubtaskLifeCycle.java} | 22 +-
...er.java => SubscriptionSinkSubtaskManager.java} | 70 +-
.../agent/plugin/PipeDataNodePluginAgentTest.java | 20 +-
...rTest.java => PipeSinkSubtaskExecutorTest.java} | 10 +-
.../db/pipe/consensus/DeletionResourceTest.java | 12 +-
.../pattern/CachedSchemaPatternMatcherTest.java | 29 +-
.../PipeDataNodeThriftRequestTest.java | 34 +-
.../pipe/{connector => sink}/PipeReceiverTest.java | 6 +-
.../PipeSinkTest.java} | 34 +-
.../PipeStatementTablePatternParseVisitorTest.java | 2 +-
.../PipeStatementTreePatternParseVisitorTest.java | 2 +-
.../PipeTabletEventSorterTest.java | 6 +-
.../IoTDBDataRegionSourceTest.java} | 30 +-
.../PipePlanTablePatternParseVisitorTest.java | 12 +-
.../PipePlanTreePatternParseVisitorTest.java | 34 +-
.../PipeRealtimeExtractTest.java | 43 +-
.../SchemaRegionListeningQueueTest.java | 2 +-
.../apache/iotdb/commons/conf/CommonConfig.java | 49 --
...sensusRetryWithIncreasingIntervalException.java | 2 +-
.../exception/pipe/PipeRuntimeExceptionType.java | 4 +-
....java => PipeRuntimeSinkCriticalException.java} | 24 +-
...untimeSinkRetryTimesConfigurableException.java} | 6 +-
.../commons/pipe/agent/plugin/PipePluginAgent.java | 16 +-
.../agent/plugin/builtin/BuiltinPipePlugin.java | 97 ++-
.../PlaceholderSink.java} | 6 +-
.../donothing/DoNothingSink.java} | 4 +-
.../iotdb/airgap/IoTDBAirGapSink.java} | 6 +-
.../iotdb/consensus/PipeConsensusAsyncSink.java} | 6 +-
.../iotdb/thrift/IoTDBLegacyPipeSink.java} | 6 +-
.../iotdb/thrift/IoTDBThriftAsyncSink.java} | 4 +-
.../iotdb/thrift/IoTDBThriftSink.java} | 6 +-
.../iotdb/thrift/IoTDBThriftSslSink.java} | 6 +-
.../iotdb/thrift/IoTDBThriftSyncSink.java} | 4 +-
.../opcda/OpcDaSink.java} | 6 +-
.../opcua/OpcUaSink.java} | 6 +-
.../websocket/WebSocketSink.java} | 6 +-
.../writeback/WriteBackSink.java} | 6 +-
.../donothing/DoNothingSource.java} | 4 +-
.../iotdb/IoTDBSource.java} | 4 +-
.../mqtt/MQTTSource.java} | 4 +-
...orConstructor.java => PipeSinkConstructor.java} | 11 +-
...Constructor.java => PipeSourceConstructor.java} | 11 +-
.../commons/pipe/agent/task/PipeTaskAgent.java | 12 +-
.../pipe/agent/task/meta/PipeRuntimeMeta.java | 6 +-
.../pipe/agent/task/meta/PipeStaticMeta.java | 5 +-
.../commons/pipe/agent/task/meta/PipeTaskMeta.java | 4 +-
...orSubtask.java => PipeAbstractSinkSubtask.java} | 16 +-
.../agent/task/subtask/PipeReportableSubtask.java | 6 +-
.../iotdb/commons/pipe/config/PipeConfig.java | 22 -
.../iotdb/commons/pipe/config/PipeDescriptor.java | 16 -
...onnectorConstant.java => PipeSinkConstant.java} | 4 +-
...ractorConstant.java => PipeSourceConstant.java} | 4 +-
...nt.java => PipeTaskSinkRuntimeEnvironment.java} | 4 +-
.../options/PipeInclusionOptions.java | 12 +-
.../datastructure/pattern/IoTDBTreePattern.java | 4 +-
.../datastructure/pattern/PrefixTreePattern.java | 4 +-
.../pipe/datastructure/pattern/TablePattern.java | 32 +-
.../pipe/datastructure/pattern/TreePattern.java | 28 +-
.../datastructure/visibility/VisibilityUtils.java | 16 +-
.../commons/pipe/receiver/IoTDBFileReceiver.java | 32 +-
.../iotdb/commons/pipe/receiver/IoTDBReceiver.java | 4 +-
.../pipe/receiver/PipeReceiverStatusHandler.java | 12 +-
.../client/IoTDBClientManager.java | 2 +-
.../client/IoTDBSyncClient.java | 8 +-
.../client/IoTDBSyncClientManager.java | 14 +-
.../compressor/PipeCompressor.java | 2 +-
.../compressor/PipeCompressorConfig.java | 2 +-
.../compressor/PipeCompressorFactory.java | 14 +-
.../compressor/PipeGZIPCompressor.java | 2 +-
.../compressor/PipeLZ4Compressor.java | 2 +-
.../compressor/PipeLZMA2Compressor.java | 2 +-
.../compressor/PipeSnappyCompressor.java | 2 +-
.../compressor/PipeZSTDCompressor.java | 2 +-
.../limiter/GlobalRPCRateLimiter.java | 2 +-
.../limiter/GlobalRateLimiter.java | 2 +-
.../limiter/PipeEndPointRateLimiter.java | 2 +-
.../limiter/TsFileSendRateLimiter.java | 2 +-
.../payload/airgap/AirGapELanguageConstant.java | 2 +-
.../payload/airgap/AirGapOneByteResponse.java | 2 +-
.../airgap/AirGapPseudoTPipeTransferRequest.java | 2 +-
.../request/PipeConsensusRequestType.java | 2 +-
.../request/PipeConsensusRequestVersion.java | 2 +-
.../request/PipeConsensusTransferFilePieceReq.java | 2 +-
.../request/PipeConsensusTransferFileSealReq.java | 2 +-
.../PipeConsensusTransferFileSealWithModReq.java | 2 +-
.../PipeConsensusTransferFilePieceResp.java | 2 +-
.../common/PipeTransferHandshakeConstant.java | 2 +-
.../thrift/common/PipeTransferSliceReqHandler.java | 8 +-
.../thrift/request/IoTDBSinkRequestVersion.java} | 6 +-
.../payload/thrift/request/PipeRequestType.java | 2 +-
.../thrift/request/PipeTransferCompressedReq.java | 10 +-
.../thrift/request/PipeTransferFilePieceReq.java | 6 +-
.../thrift/request/PipeTransferFileSealReqV1.java | 6 +-
.../thrift/request/PipeTransferFileSealReqV2.java | 6 +-
.../thrift/request/PipeTransferHandshakeV1Req.java | 6 +-
.../thrift/request/PipeTransferHandshakeV2Req.java | 6 +-
.../thrift/request/PipeTransferSliceReq.java | 4 +-
.../thrift/response/PipeTransferFilePieceResp.java | 2 +-
.../protocol/IoTDBAirGapSink.java} | 28 +-
.../protocol/IoTDBSink.java} | 200 +++--
.../protocol/IoTDBSslSyncSink.java} | 30 +-
.../IoTDBNonDataRegionSource.java} | 10 +-
.../IoTDBSource.java} | 58 +-
.../commons/subscription/meta/topic/TopicMeta.java | 6 +-
.../exception/pipe/PipeRuntimeExceptionTest.java | 9 +-
.../pipe/plugin/builtin/BuiltinPipePluginTest.java | 16 +-
.../iotdb/commons/pipe/task/PipeMetaDeSerTest.java | 4 +-
376 files changed, 4284 insertions(+), 3407 deletions(-)
create mode 100644
integration-test/src/test/java/org/apache/iotdb/confignode/it/regionmigration/pass/daily/iotv1/IoTDBRegionMigrateWithLastEmptyDeletionIT.java
rename
integration-test/src/test/java/org/apache/iotdb/pipe/it/dual/tablemodel/manual/basic/{IoTDBPipeExtractorIT.java
=> IoTDBPipeSourceIT.java} (99%)
rename
integration-test/src/test/java/org/apache/iotdb/pipe/it/dual/tablemodel/manual/enhanced/{IoTDBPipeConnectorCompressionIT.java
=> IoTDBPipeSinkCompressionIT.java} (99%)
rename
integration-test/src/test/java/org/apache/iotdb/pipe/it/dual/tablemodel/manual/enhanced/{IoTDBPipeConnectorParallelIT.java
=> IoTDBPipeSinkParallelIT.java} (98%)
rename
integration-test/src/test/java/org/apache/iotdb/pipe/it/dual/treemodel/auto/basic/{IoTDBPipeConnectorParallelIT.java
=> IoTDBPipeSinkParallelIT.java} (97%)
rename
integration-test/src/test/java/org/apache/iotdb/pipe/it/dual/treemodel/auto/basic/{IoTDBPipeExtractorIT.java
=> IoTDBPipeSourceIT.java} (99%)
rename
integration-test/src/test/java/org/apache/iotdb/pipe/it/dual/treemodel/auto/enhanced/{IoTDBPipeConnectorCompressionIT.java
=> IoTDBPipeSinkCompressionIT.java} (99%)
copy {iotdb-client/client-py/iotdb =>
iotdb-core/ainode/ainode/core/inference/scheduler}/__init__.py (100%)
create mode 100644
iotdb-core/ainode/ainode/core/inference/scheduler/abstract_scheduler.py
create mode 100644
iotdb-core/ainode/ainode/core/inference/scheduler/basic_scheduler.py
rename
iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/manager/pipe/agent/plugin/{PipeConfigRegionConnectorConstructor.java
=> PipeConfigRegionSinkConstructor.java} (70%)
rename
iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/manager/pipe/agent/plugin/{PipeConfigRegionExtractorConstructor.java
=> PipeConfigRegionSourceConstructor.java} (75%)
rename
iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/manager/pipe/metric/sink/{PipeConfigRegionConnectorMetrics.java
=> PipeConfigRegionSinkMetrics.java} (92%)
rename
iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/manager/pipe/metric/source/{PipeConfigRegionExtractorMetrics.java
=> PipeConfigRegionSourceMetrics.java} (82%)
rename
iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/manager/pipe/{connector
=> sink}/client/IoTDBConfigNodeSyncClientManager.java (85%)
rename
iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/manager/pipe/{connector
=> sink}/payload/PipeTransferConfigNodeHandshakeV1Req.java (90%)
rename
iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/manager/pipe/{connector
=> sink}/payload/PipeTransferConfigNodeHandshakeV2Req.java (90%)
rename
iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/manager/pipe/{connector
=> sink}/payload/PipeTransferConfigPlanReq.java (86%)
rename
iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/manager/pipe/{connector
=> sink}/payload/PipeTransferConfigSnapshotPieceReq.java (90%)
rename
iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/manager/pipe/{connector
=> sink}/payload/PipeTransferConfigSnapshotSealReq.java (95%)
rename
iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/manager/pipe/{connector/protocol/IoTDBConfigRegionAirGapConnector.java
=> sink/protocol/IoTDBConfigRegionAirGapSink.java} (89%)
rename
iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/manager/pipe/{connector/protocol/IoTDBConfigRegionConnector.java
=> sink/protocol/IoTDBConfigRegionSink.java} (90%)
rename
iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/manager/pipe/{extractor
=> source}/ConfigRegionListeningFilter.java (99%)
rename
iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/manager/pipe/{extractor
=> source}/ConfigRegionListeningQueue.java (99%)
rename
iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/manager/pipe/{extractor/IoTDBConfigRegionExtractor.java
=> source/IoTDBConfigRegionSource.java} (97%)
rename
iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/manager/pipe/{extractor
=> source}/PipeConfigPhysicalPlanTablePatternParseVisitor.java (99%)
rename
iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/manager/pipe/{extractor
=> source}/PipeConfigPhysicalPlanTablePrivilegeParseVisitor.java (99%)
rename
iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/manager/pipe/{extractor
=> source}/PipeConfigPhysicalPlanTableScopeParseVisitor.java (98%)
rename
iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/manager/pipe/{extractor
=> source}/PipeConfigPhysicalPlanTreePatternParseVisitor.java (99%)
rename
iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/manager/pipe/{extractor
=> source}/PipeConfigPhysicalPlanTreeScopeParseVisitor.java (98%)
rename
iotdb-core/confignode/src/test/java/org/apache/iotdb/confignode/manager/pipe/{connector/IoTDBConfigRegionConnectorTest.java
=> sink/IoTDBConfigRegionSinkTest.java} (72%)
rename
iotdb-core/confignode/src/test/java/org/apache/iotdb/confignode/manager/pipe/{connector
=> sink}/PipeConfigNodeThriftRequestTest.java (89%)
rename
iotdb-core/confignode/src/test/java/org/apache/iotdb/confignode/manager/pipe/{extractor/IoTDBConfigRegionExtractorTest.java
=> source/IoTDBConfigRegionSourceTest.java} (64%)
rename
iotdb-core/confignode/src/test/java/org/apache/iotdb/confignode/manager/pipe/{extractor
=> source}/PipeConfigPhysicalPlanScopeParseVisitorTest.java (96%)
rename
iotdb-core/confignode/src/test/java/org/apache/iotdb/confignode/manager/pipe/{extractor
=> source}/PipeConfigPhysicalPlanTablePatternParseVisitorTest.java (97%)
rename
iotdb-core/confignode/src/test/java/org/apache/iotdb/confignode/manager/pipe/{extractor
=> source}/PipeConfigPhysicalPlanTreePatternParseVisitorTest.java (91%)
rename
iotdb-core/consensus/src/main/java/org/apache/iotdb/consensus/pipe/consensuspipe/{ConsensusPipeConnector.java
=> ConsensusPipeSink.java} (95%)
rename
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/agent/plugin/dataregion/{PipeDataRegionConnectorConstructor.java
=> PipeDataRegionSinkConstructor.java} (60%)
rename
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/agent/plugin/dataregion/{PipeDataRegionExtractorConstructor.java
=> PipeDataRegionSourceConstructor.java} (70%)
rename
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/agent/plugin/schemaregion/{PipeSchemaRegionConnectorConstructor.java
=> PipeSchemaRegionSinkConstructor.java} (70%)
rename
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/agent/plugin/schemaregion/{PipeSchemaRegionExtractorConstructor.java
=> PipeSchemaRegionSourceConstructor.java} (75%)
rename
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/agent/task/execution/{PipeConnectorSubtaskExecutor.java
=> PipeSinkSubtaskExecutor.java} (88%)
rename
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/agent/task/stage/{PipeTaskConnectorStage.java
=> PipeTaskSinkStage.java} (72%)
rename
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/agent/task/stage/{PipeTaskExtractorStage.java
=> PipeTaskSourceStage.java} (97%)
rename
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/agent/task/subtask/{connector
=> sink}/PipeRealtimePriorityBlockingQueue.java (99%)
rename
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/agent/task/subtask/{connector/PipeConnectorSubtask.java
=> sink/PipeSinkSubtask.java} (83%)
rename
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/agent/task/subtask/{connector/PipeConnectorSubtaskLifeCycle.java
=> sink/PipeSinkSubtaskLifeCycle.java} (77%)
rename
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/agent/task/subtask/{connector/PipeConnectorSubtaskManager.java
=> sink/PipeSinkSubtaskManager.java} (80%)
rename
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/consensus/metric/{PipeConsensusConnectorMetrics.java
=> PipeConsensusSinkMetrics.java} (95%)
delete mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/extractor/dataregion/realtime/PipeRealtimeDataRegionHybridExtractor.java
rename
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/metric/schema/{PipeSchemaRegionConnectorMetrics.java
=> PipeSchemaRegionSinkMetrics.java} (79%)
rename
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/metric/schema/{PipeSchemaRegionExtractorMetrics.java
=> PipeSchemaRegionSourceMetrics.java} (82%)
rename
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/metric/sink/{PipeDataRegionConnectorMetrics.java
=> PipeDataRegionSinkMetrics.java} (90%)
rename
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/metric/source/{PipeDataRegionExtractorMetrics.java
=> PipeDataRegionSourceMetrics.java} (87%)
rename iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/{connector
=> sink}/client/IoTDBDataNodeAsyncClientManager.java (96%)
rename iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/{connector
=> sink}/client/IoTDBDataNodeCacheLeaderClientManager.java (99%)
rename iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/{connector
=> sink}/client/IoTDBDataNodeSyncClientManager.java (89%)
rename iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/{connector
=> sink}/payload/evolvable/batch/PipeTabletEventBatch.java (97%)
rename iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/{connector
=> sink}/payload/evolvable/batch/PipeTabletEventPlainBatch.java (94%)
rename iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/{connector
=> sink}/payload/evolvable/batch/PipeTabletEventTsFileBatch.java (91%)
rename iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/{connector
=> sink}/payload/evolvable/batch/PipeTransferBatchReqBuilder.java (88%)
rename iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/{connector
=> sink}/payload/evolvable/request/PipeTransferDataNodeHandshakeV1Req.java (90%)
rename iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/{connector
=> sink}/payload/evolvable/request/PipeTransferDataNodeHandshakeV2Req.java (90%)
rename iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/{connector
=> sink}/payload/evolvable/request/PipeTransferPlanNodeReq.java (88%)
rename iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/{connector
=> sink}/payload/evolvable/request/PipeTransferSchemaSnapshotPieceReq.java (90%)
rename iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/{connector
=> sink}/payload/evolvable/request/PipeTransferSchemaSnapshotSealReq.java (95%)
rename iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/{connector
=> sink}/payload/evolvable/request/PipeTransferTabletBatchReq.java (96%)
rename iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/{connector
=> sink}/payload/evolvable/request/PipeTransferTabletBatchReqV2.java (96%)
rename iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/{connector
=> sink}/payload/evolvable/request/PipeTransferTabletBinaryReq.java (91%)
rename iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/{connector
=> sink}/payload/evolvable/request/PipeTransferTabletBinaryReqV2.java (92%)
rename iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/{connector
=> sink}/payload/evolvable/request/PipeTransferTabletInsertNodeReq.java (90%)
rename iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/{connector
=> sink}/payload/evolvable/request/PipeTransferTabletInsertNodeReqV2.java (92%)
rename iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/{connector
=> sink}/payload/evolvable/request/PipeTransferTabletRawReq.java (92%)
rename iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/{connector
=> sink}/payload/evolvable/request/PipeTransferTabletRawReqV2.java (91%)
rename iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/{connector
=> sink}/payload/evolvable/request/PipeTransferTsFilePieceReq.java (90%)
rename iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/{connector
=> sink}/payload/evolvable/request/PipeTransferTsFilePieceWithModReq.java (90%)
rename iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/{connector
=> sink}/payload/evolvable/request/PipeTransferTsFileSealReq.java (89%)
rename iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/{connector
=> sink}/payload/evolvable/request/PipeTransferTsFileSealWithModReq.java (95%)
rename iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/{connector
=> sink}/payload/legacy/DeletionPipeData.java (97%)
rename iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/{connector
=> sink}/payload/legacy/PipeData.java (98%)
rename iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/{connector
=> sink}/payload/legacy/TsFilePipeData.java (98%)
rename
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/{connector/protocol/airgap/IoTDBDataNodeAirGapConnector.java
=> sink/protocol/airgap/IoTDBDataNodeAirGapSink.java} (83%)
rename
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/{connector/protocol/airgap/IoTDBDataRegionAirGapConnector.java
=> sink/protocol/airgap/IoTDBDataRegionAirGapSink.java} (89%)
rename
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/{connector/protocol/airgap/IoTDBSchemaRegionAirGapConnector.java
=> sink/protocol/airgap/IoTDBSchemaRegionAirGapSink.java} (91%)
rename
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/{connector/protocol/legacy/IoTDBLegacyPipeConnector.java
=> sink/protocol/legacy/IoTDBLegacyPipeSink.java} (90%)
rename iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/{connector
=> sink}/protocol/opcda/OpcDaHeader.java (99%)
rename iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/{connector
=> sink}/protocol/opcda/OpcDaServerHandle.java (96%)
rename
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/{connector/protocol/opcda/OpcDaConnector.java
=> sink/protocol/opcda/OpcDaSink.java} (92%)
rename iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/{connector
=> sink}/protocol/opcua/OpcUaKeyStoreLoader.java (98%)
rename iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/{connector
=> sink}/protocol/opcua/OpcUaNameSpace.java (98%)
rename iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/{connector
=> sink}/protocol/opcua/OpcUaServerBuilder.java (95%)
rename
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/{connector/protocol/opcua/OpcUaConnector.java
=> sink/protocol/opcua/OpcUaSink.java} (88%)
rename
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/{connector/protocol/pipeconsensus/PipeConsensusAsyncConnector.java
=> sink/protocol/pipeconsensus/PipeConsensusAsyncSink.java} (87%)
rename
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/{connector/protocol/pipeconsensus/PipeConsensusSyncConnector.java
=> sink/protocol/pipeconsensus/PipeConsensusSyncSink.java} (88%)
rename iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/{connector
=> sink}/protocol/pipeconsensus/handler/PipeConsensusDeleteEventHandler.java
(90%)
rename iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/{connector
=>
sink}/protocol/pipeconsensus/handler/PipeConsensusTabletBatchEventHandler.java
(85%)
rename iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/{connector
=>
sink}/protocol/pipeconsensus/handler/PipeConsensusTabletInsertNodeEventHandler.java
(83%)
rename iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/{connector
=>
sink}/protocol/pipeconsensus/handler/PipeConsensusTabletInsertionEventHandler.java
(89%)
rename iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/{connector
=>
sink}/protocol/pipeconsensus/handler/PipeConsensusTsFileInsertionEventHandler.java
(91%)
rename iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/{connector
=>
sink}/protocol/pipeconsensus/payload/builder/PipeConsensusAsyncBatchReqBuilder.java
(94%)
rename iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/{connector
=>
sink}/protocol/pipeconsensus/payload/builder/PipeConsensusSyncBatchReqBuilder.java
(95%)
rename iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/{connector
=>
sink}/protocol/pipeconsensus/payload/builder/PipeConsensusTransferBatchReqBuilder.java
(91%)
rename iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/{connector
=> sink}/protocol/pipeconsensus/payload/request/PipeConsensusDeleteNodeReq.java
(94%)
rename iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/{connector
=>
sink}/protocol/pipeconsensus/payload/request/PipeConsensusTabletBatchReq.java
(97%)
rename iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/{connector
=>
sink}/protocol/pipeconsensus/payload/request/PipeConsensusTabletBinaryReq.java
(94%)
rename iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/{connector
=>
sink}/protocol/pipeconsensus/payload/request/PipeConsensusTabletInsertNodeReq.java
(95%)
rename iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/{connector
=>
sink}/protocol/pipeconsensus/payload/request/PipeConsensusTsFilePieceReq.java
(89%)
rename iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/{connector
=>
sink}/protocol/pipeconsensus/payload/request/PipeConsensusTsFilePieceWithModReq.java
(89%)
rename iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/{connector
=> sink}/protocol/pipeconsensus/payload/request/PipeConsensusTsFileSealReq.java
(89%)
rename iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/{connector
=>
sink}/protocol/pipeconsensus/payload/request/PipeConsensusTsFileSealWithModReq.java
(90%)
rename
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/{connector/protocol/thrift/async/IoTDBDataRegionAsyncConnector.java
=> sink/protocol/thrift/async/IoTDBDataRegionAsyncSink.java} (89%)
rename iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/{connector
=> sink}/protocol/thrift/async/handler/PipeTransferTabletBatchEventHandler.java
(93%)
rename iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/{connector
=>
sink}/protocol/thrift/async/handler/PipeTransferTabletInsertNodeEventHandler.java
(89%)
rename iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/{connector
=>
sink}/protocol/thrift/async/handler/PipeTransferTabletInsertionEventHandler.java
(94%)
rename iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/{connector
=> sink}/protocol/thrift/async/handler/PipeTransferTabletRawEventHandler.java
(88%)
rename iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/{connector
=> sink}/protocol/thrift/async/handler/PipeTransferTrackableHandler.java (93%)
rename iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/{connector
=> sink}/protocol/thrift/async/handler/PipeTransferTsFileHandler.java (95%)
rename
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/{connector/protocol/thrift/sync/IoTDBDataNodeSyncConnector.java
=> sink/protocol/thrift/sync/IoTDBDataNodeSyncSink.java} (85%)
rename
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/{connector/protocol/thrift/sync/IoTDBDataRegionSyncConnector.java
=> sink/protocol/thrift/sync/IoTDBDataRegionSyncSink.java} (89%)
rename
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/{connector/protocol/thrift/sync/IoTDBSchemaRegionConnector.java
=> sink/protocol/thrift/sync/IoTDBSchemaRegionSink.java} (92%)
rename iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/{connector
=> sink}/protocol/websocket/WebSocketConnectorServer.java (96%)
rename
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/{connector/protocol/websocket/WebSocketConnector.java
=> sink/protocol/websocket/WebSocketSink.java} (91%)
rename
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/{connector/protocol/writeback/WriteBackConnector.java
=> sink/protocol/writeback/WriteBackSink.java} (93%)
rename iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/{connector
=> sink}/util/builder/PipeTableModelTsFileBuilder.java (99%)
rename iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/{connector
=> sink}/util/builder/PipeTableModelTsFileBuilderV2.java (99%)
rename iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/{connector
=> sink}/util/builder/PipeTreeModelTsFileBuilder.java (99%)
rename iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/{connector
=> sink}/util/builder/PipeTreeModelTsFileBuilderV2.java (99%)
rename iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/{connector
=> sink}/util/builder/PipeTsFileBuilder.java (99%)
rename iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/{connector
=> sink}/util/cacher/LeaderCacheUtils.java (97%)
rename iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/{connector
=> sink}/util/sorter/PipeTableModelTabletEventSorter.java (99%)
rename iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/{connector
=> sink}/util/sorter/PipeTabletEventSorter.java (99%)
rename iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/{connector
=> sink}/util/sorter/PipeTreeModelTabletEventSorter.java (98%)
rename iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/{extractor
=> source}/dataregion/DataRegionListeningFilter.java (99%)
rename iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/{extractor
=> source}/dataregion/DataRegionWatermarkInjector.java (97%)
rename
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/{extractor/dataregion/IoTDBDataRegionExtractor.java
=> source/dataregion/IoTDBDataRegionSource.java} (82%)
rename
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/{extractor/dataregion/historical/PipeHistoricalDataRegionExtractor.java
=> source/dataregion/historical/PipeHistoricalDataRegionSource.java} (86%)
rename
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/{extractor/dataregion/historical/PipeHistoricalDataRegionTsFileAndDeletionExtractor.java
=>
source/dataregion/historical/PipeHistoricalDataRegionTsFileAndDeletionSource.java}
(94%)
rename
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/{extractor/dataregion/realtime/PipeRealtimeDataRegionHeartbeatExtractor.java
=> source/dataregion/realtime/PipeRealtimeDataRegionHeartbeatSource.java} (89%)
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/source/dataregion/realtime/PipeRealtimeDataRegionHybridSource.java
rename
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/{extractor/dataregion/realtime/PipeRealtimeDataRegionLogExtractor.java
=> source/dataregion/realtime/PipeRealtimeDataRegionLogSource.java} (88%)
rename
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/{extractor/dataregion/realtime/PipeRealtimeDataRegionExtractor.java
=> source/dataregion/realtime/PipeRealtimeDataRegionSource.java} (89%)
rename
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/{extractor/dataregion/realtime/PipeRealtimeDataRegionTsFileExtractor.java
=> source/dataregion/realtime/PipeRealtimeDataRegionTsFileSource.java} (86%)
rename iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/{extractor
=> source}/dataregion/realtime/assigner/DisruptorQueue.java (98%)
rename iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/{extractor
=> source}/dataregion/realtime/assigner/DisruptorQueueExceptionHandler.java
(95%)
rename iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/{extractor
=> source}/dataregion/realtime/assigner/PipeDataRegionAssigner.java (95%)
rename iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/{extractor
=> source}/dataregion/realtime/assigner/PipeTsFileEpochProgressIndexKeeper.java
(97%)
rename iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/{extractor
=> source}/dataregion/realtime/epoch/TsFileEpoch.java (85%)
rename iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/{extractor
=> source}/dataregion/realtime/epoch/TsFileEpochManager.java (98%)
rename iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/{extractor
=> source}/dataregion/realtime/epoch/TsFileEpochStateMigrator.java (93%)
rename iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/{extractor
=> source}/dataregion/realtime/listener/PipeInsertionDataNodeListener.java (94%)
rename iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/{extractor
=> source}/dataregion/realtime/listener/PipeTimePartitionListener.java (87%)
rename iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/{extractor
=> source}/dataregion/realtime/matcher/CachedSchemaPatternMatcher.java (86%)
rename iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/{extractor
=> source}/dataregion/realtime/matcher/PipeDataRegionMatcher.java (82%)
rename iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/{extractor
=> source}/mqtt/MQTTPublishHandler.java (97%)
rename
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/{extractor/mqtt/MQTTExtractor.java
=> source/mqtt/MQTTSource.java} (77%)
rename
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/{extractor/schemaregion/IoTDBSchemaRegionExtractor.java
=> source/schemaregion/IoTDBSchemaRegionSource.java} (96%)
rename iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/{extractor
=> source}/schemaregion/PipePlanTablePatternParseVisitor.java (98%)
rename iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/{extractor
=> source}/schemaregion/PipePlanTablePrivilegeParseVisitor.java (98%)
rename iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/{extractor
=> source}/schemaregion/PipePlanTreePatternParseVisitor.java (99%)
rename iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/{extractor
=> source}/schemaregion/PipeStatementToPlanVisitor.java (97%)
rename iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/{extractor
=> source}/schemaregion/SchemaRegionListeningFilter.java (99%)
rename iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/{extractor
=> source}/schemaregion/SchemaRegionListeningQueue.java (98%)
rename
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/subscription/task/stage/{SubscriptionTaskConnectorStage.java
=> SubscriptionTaskSinkStage.java} (71%)
rename
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/subscription/task/subtask/{SubscriptionConnectorSubtask.java
=> SubscriptionSinkSubtask.java} (92%)
rename
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/subscription/task/subtask/{SubscriptionConnectorSubtaskLifeCycle.java
=> SubscriptionSinkSubtaskLifeCycle.java} (77%)
rename
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/subscription/task/subtask/{SubscriptionConnectorSubtaskManager.java
=> SubscriptionSinkSubtaskManager.java} (76%)
rename
iotdb-core/datanode/src/test/java/org/apache/iotdb/db/pipe/agent/task/{PipeConnectorSubtaskExecutorTest.java
=> PipeSinkSubtaskExecutorTest.java} (81%)
rename iotdb-core/datanode/src/test/java/org/apache/iotdb/db/pipe/{connector
=> sink}/PipeDataNodeThriftRequestTest.java (93%)
rename iotdb-core/datanode/src/test/java/org/apache/iotdb/db/pipe/{connector
=> sink}/PipeReceiverTest.java (88%)
rename
iotdb-core/datanode/src/test/java/org/apache/iotdb/db/pipe/{connector/PipeConnectorTest.java
=> sink/PipeSinkTest.java} (65%)
rename iotdb-core/datanode/src/test/java/org/apache/iotdb/db/pipe/{connector
=> sink}/PipeStatementTablePatternParseVisitorTest.java (98%)
rename iotdb-core/datanode/src/test/java/org/apache/iotdb/db/pipe/{connector
=> sink}/PipeStatementTreePatternParseVisitorTest.java (99%)
rename iotdb-core/datanode/src/test/java/org/apache/iotdb/db/pipe/{connector
=> sink}/PipeTabletEventSorterTest.java (98%)
rename
iotdb-core/datanode/src/test/java/org/apache/iotdb/db/pipe/{extractor/IoTDBDataRegionExtractorTest.java
=> source/IoTDBDataRegionSourceTest.java} (77%)
rename iotdb-core/datanode/src/test/java/org/apache/iotdb/db/pipe/{extractor
=> source}/PipePlanTablePatternParseVisitorTest.java (92%)
rename iotdb-core/datanode/src/test/java/org/apache/iotdb/db/pipe/{extractor
=> source}/PipePlanTreePatternParseVisitorTest.java (94%)
rename iotdb-core/datanode/src/test/java/org/apache/iotdb/db/pipe/{extractor
=> source}/PipeRealtimeExtractTest.java (88%)
rename iotdb-core/datanode/src/test/java/org/apache/iotdb/db/pipe/{extractor
=> source}/SchemaRegionListeningQueueTest.java (99%)
rename
iotdb-core/node-commons/src/main/java/org/apache/iotdb/commons/exception/pipe/{PipeRuntimeConnectorCriticalException.java
=> PipeRuntimeSinkCriticalException.java} (75%)
rename
iotdb-core/node-commons/src/main/java/org/apache/iotdb/commons/exception/pipe/{PipeRuntimeConnectorRetryTimesConfigurableException.java
=> PipeRuntimeSinkRetryTimesConfigurableException.java} (85%)
rename
iotdb-core/node-commons/src/main/java/org/apache/iotdb/commons/pipe/agent/plugin/builtin/{connector/PlaceholderConnector.java
=> sink/PlaceholderSink.java} (95%)
rename
iotdb-core/node-commons/src/main/java/org/apache/iotdb/commons/pipe/agent/plugin/builtin/{connector/donothing/DoNothingConnector.java
=> sink/donothing/DoNothingSink.java} (93%)
rename
iotdb-core/node-commons/src/main/java/org/apache/iotdb/commons/pipe/agent/plugin/builtin/{connector/iotdb/airgap/IoTDBAirGapConnector.java
=> sink/iotdb/airgap/IoTDBAirGapSink.java} (84%)
rename
iotdb-core/node-commons/src/main/java/org/apache/iotdb/commons/pipe/agent/plugin/builtin/{connector/iotdb/consensus/PipeConsensusAsyncConnector.java
=> sink/iotdb/consensus/PipeConsensusAsyncSink.java} (83%)
rename
iotdb-core/node-commons/src/main/java/org/apache/iotdb/commons/pipe/agent/plugin/builtin/{connector/iotdb/thrift/IoTDBLegacyPipeConnector.java
=> sink/iotdb/thrift/IoTDBLegacyPipeSink.java} (83%)
rename
iotdb-core/node-commons/src/main/java/org/apache/iotdb/commons/pipe/agent/plugin/builtin/{connector/iotdb/thrift/IoTDBThriftAsyncConnector.java
=> sink/iotdb/thrift/IoTDBThriftAsyncSink.java} (89%)
rename
iotdb-core/node-commons/src/main/java/org/apache/iotdb/commons/pipe/agent/plugin/builtin/{connector/iotdb/thrift/IoTDBThriftConnector.java
=> sink/iotdb/thrift/IoTDBThriftSink.java} (84%)
rename
iotdb-core/node-commons/src/main/java/org/apache/iotdb/commons/pipe/agent/plugin/builtin/{connector/iotdb/thrift/IoTDBThriftSslConnector.java
=> sink/iotdb/thrift/IoTDBThriftSslSink.java} (84%)
rename
iotdb-core/node-commons/src/main/java/org/apache/iotdb/commons/pipe/agent/plugin/builtin/{connector/iotdb/thrift/IoTDBThriftSyncConnector.java
=> sink/iotdb/thrift/IoTDBThriftSyncSink.java} (89%)
rename
iotdb-core/node-commons/src/main/java/org/apache/iotdb/commons/pipe/agent/plugin/builtin/{connector/opcda/OpcDaConnector.java
=> sink/opcda/OpcDaSink.java} (84%)
rename
iotdb-core/node-commons/src/main/java/org/apache/iotdb/commons/pipe/agent/plugin/builtin/{connector/opcua/OpcUaConnector.java
=> sink/opcua/OpcUaSink.java} (84%)
rename
iotdb-core/node-commons/src/main/java/org/apache/iotdb/commons/pipe/agent/plugin/builtin/{connector/websocket/WebSocketConnector.java
=> sink/websocket/WebSocketSink.java} (83%)
rename
iotdb-core/node-commons/src/main/java/org/apache/iotdb/commons/pipe/agent/plugin/builtin/{connector/writeback/WriteBackConnector.java
=> sink/writeback/WriteBackSink.java} (84%)
rename
iotdb-core/node-commons/src/main/java/org/apache/iotdb/commons/pipe/agent/plugin/builtin/{extractor/donothing/DoNothingExtractor.java
=> source/donothing/DoNothingSource.java} (92%)
rename
iotdb-core/node-commons/src/main/java/org/apache/iotdb/commons/pipe/agent/plugin/builtin/{extractor/iotdb/IoTDBExtractor.java
=> source/iotdb/IoTDBSource.java} (95%)
rename
iotdb-core/node-commons/src/main/java/org/apache/iotdb/commons/pipe/agent/plugin/builtin/{extractor/mqtt/MQTTExtractor.java
=> source/mqtt/MQTTSource.java} (95%)
rename
iotdb-core/node-commons/src/main/java/org/apache/iotdb/commons/pipe/agent/plugin/constructor/{PipeConnectorConstructor.java
=> PipeSinkConstructor.java} (80%)
rename
iotdb-core/node-commons/src/main/java/org/apache/iotdb/commons/pipe/agent/plugin/constructor/{PipeExtractorConstructor.java
=> PipeSourceConstructor.java} (80%)
rename
iotdb-core/node-commons/src/main/java/org/apache/iotdb/commons/pipe/agent/task/subtask/{PipeAbstractConnectorSubtask.java
=> PipeAbstractSinkSubtask.java} (94%)
rename
iotdb-core/node-commons/src/main/java/org/apache/iotdb/commons/pipe/config/constant/{PipeConnectorConstant.java
=> PipeSinkConstant.java} (99%)
rename
iotdb-core/node-commons/src/main/java/org/apache/iotdb/commons/pipe/config/constant/{PipeExtractorConstant.java
=> PipeSourceConstant.java} (99%)
rename
iotdb-core/node-commons/src/main/java/org/apache/iotdb/commons/pipe/config/plugin/env/{PipeTaskConnectorRuntimeEnvironment.java
=> PipeTaskSinkRuntimeEnvironment.java} (90%)
rename
iotdb-core/node-commons/src/main/java/org/apache/iotdb/commons/pipe/{connector
=> sink}/client/IoTDBClientManager.java (98%)
rename
iotdb-core/node-commons/src/main/java/org/apache/iotdb/commons/pipe/{connector
=> sink}/client/IoTDBSyncClient.java (94%)
rename
iotdb-core/node-commons/src/main/java/org/apache/iotdb/commons/pipe/{connector
=> sink}/client/IoTDBSyncClientManager.java (96%)
rename
iotdb-core/node-commons/src/main/java/org/apache/iotdb/commons/pipe/{connector
=> sink}/compressor/PipeCompressor.java (97%)
rename
iotdb-core/node-commons/src/main/java/org/apache/iotdb/commons/pipe/{connector
=> sink}/compressor/PipeCompressorConfig.java (95%)
rename
iotdb-core/node-commons/src/main/java/org/apache/iotdb/commons/pipe/{connector
=> sink}/compressor/PipeCompressorFactory.java (93%)
rename
iotdb-core/node-commons/src/main/java/org/apache/iotdb/commons/pipe/{connector
=> sink}/compressor/PipeGZIPCompressor.java (96%)
rename
iotdb-core/node-commons/src/main/java/org/apache/iotdb/commons/pipe/{connector
=> sink}/compressor/PipeLZ4Compressor.java (96%)
rename
iotdb-core/node-commons/src/main/java/org/apache/iotdb/commons/pipe/{connector
=> sink}/compressor/PipeLZMA2Compressor.java (96%)
rename
iotdb-core/node-commons/src/main/java/org/apache/iotdb/commons/pipe/{connector
=> sink}/compressor/PipeSnappyCompressor.java (96%)
rename
iotdb-core/node-commons/src/main/java/org/apache/iotdb/commons/pipe/{connector
=> sink}/compressor/PipeZSTDCompressor.java (96%)
rename
iotdb-core/node-commons/src/main/java/org/apache/iotdb/commons/pipe/{connector
=> sink}/limiter/GlobalRPCRateLimiter.java (95%)
rename
iotdb-core/node-commons/src/main/java/org/apache/iotdb/commons/pipe/{connector
=> sink}/limiter/GlobalRateLimiter.java (98%)
rename
iotdb-core/node-commons/src/main/java/org/apache/iotdb/commons/pipe/{connector
=> sink}/limiter/PipeEndPointRateLimiter.java (98%)
rename
iotdb-core/node-commons/src/main/java/org/apache/iotdb/commons/pipe/{connector
=> sink}/limiter/TsFileSendRateLimiter.java (96%)
rename
iotdb-core/node-commons/src/main/java/org/apache/iotdb/commons/pipe/{connector
=> sink}/payload/airgap/AirGapELanguageConstant.java (95%)
rename
iotdb-core/node-commons/src/main/java/org/apache/iotdb/commons/pipe/{connector
=> sink}/payload/airgap/AirGapOneByteResponse.java (94%)
rename
iotdb-core/node-commons/src/main/java/org/apache/iotdb/commons/pipe/{connector
=> sink}/payload/airgap/AirGapPseudoTPipeTransferRequest.java (93%)
rename
iotdb-core/node-commons/src/main/java/org/apache/iotdb/commons/pipe/{connector
=> sink}/payload/pipeconsensus/request/PipeConsensusRequestType.java (96%)
rename
iotdb-core/node-commons/src/main/java/org/apache/iotdb/commons/pipe/{connector
=> sink}/payload/pipeconsensus/request/PipeConsensusRequestVersion.java (92%)
rename
iotdb-core/node-commons/src/main/java/org/apache/iotdb/commons/pipe/{connector
=> sink}/payload/pipeconsensus/request/PipeConsensusTransferFilePieceReq.java
(98%)
rename
iotdb-core/node-commons/src/main/java/org/apache/iotdb/commons/pipe/{connector
=> sink}/payload/pipeconsensus/request/PipeConsensusTransferFileSealReq.java
(98%)
rename
iotdb-core/node-commons/src/main/java/org/apache/iotdb/commons/pipe/{connector
=>
sink}/payload/pipeconsensus/request/PipeConsensusTransferFileSealWithModReq.java
(98%)
rename
iotdb-core/node-commons/src/main/java/org/apache/iotdb/commons/pipe/{connector
=> sink}/payload/pipeconsensus/response/PipeConsensusTransferFilePieceResp.java
(97%)
rename
iotdb-core/node-commons/src/main/java/org/apache/iotdb/commons/pipe/{connector
=> sink}/payload/thrift/common/PipeTransferHandshakeConstant.java (95%)
rename
iotdb-core/node-commons/src/main/java/org/apache/iotdb/commons/pipe/{connector
=> sink}/payload/thrift/common/PipeTransferSliceReqHandler.java (92%)
rename
iotdb-core/node-commons/src/main/java/org/apache/iotdb/commons/pipe/{connector/payload/thrift/request/IoTDBConnectorRequestVersion.java
=> sink/payload/thrift/request/IoTDBSinkRequestVersion.java} (86%)
rename
iotdb-core/node-commons/src/main/java/org/apache/iotdb/commons/pipe/{connector
=> sink}/payload/thrift/request/PipeRequestType.java (97%)
rename
iotdb-core/node-commons/src/main/java/org/apache/iotdb/commons/pipe/{connector
=> sink}/payload/thrift/request/PipeTransferCompressedReq.java (93%)
rename
iotdb-core/node-commons/src/main/java/org/apache/iotdb/commons/pipe/{connector
=> sink}/payload/thrift/request/PipeTransferFilePieceReq.java (94%)
rename
iotdb-core/node-commons/src/main/java/org/apache/iotdb/commons/pipe/{connector
=> sink}/payload/thrift/request/PipeTransferFileSealReqV1.java (93%)
rename
iotdb-core/node-commons/src/main/java/org/apache/iotdb/commons/pipe/{connector
=> sink}/payload/thrift/request/PipeTransferFileSealReqV2.java (96%)
rename
iotdb-core/node-commons/src/main/java/org/apache/iotdb/commons/pipe/{connector
=> sink}/payload/thrift/request/PipeTransferHandshakeV1Req.java (93%)
rename
iotdb-core/node-commons/src/main/java/org/apache/iotdb/commons/pipe/{connector
=> sink}/payload/thrift/request/PipeTransferHandshakeV2Req.java (94%)
rename
iotdb-core/node-commons/src/main/java/org/apache/iotdb/commons/pipe/{connector
=> sink}/payload/thrift/request/PipeTransferSliceReq.java (97%)
rename
iotdb-core/node-commons/src/main/java/org/apache/iotdb/commons/pipe/{connector
=> sink}/payload/thrift/response/PipeTransferFilePieceResp.java (97%)
rename
iotdb-core/node-commons/src/main/java/org/apache/iotdb/commons/pipe/{connector/protocol/IoTDBAirGapConnector.java
=> sink/protocol/IoTDBAirGapSink.java} (94%)
rename
iotdb-core/node-commons/src/main/java/org/apache/iotdb/commons/pipe/{connector/protocol/IoTDBConnector.java
=> sink/protocol/IoTDBSink.java} (82%)
rename
iotdb-core/node-commons/src/main/java/org/apache/iotdb/commons/pipe/{connector/protocol/IoTDBSslSyncConnector.java
=> sink/protocol/IoTDBSslSyncSink.java} (92%)
rename
iotdb-core/node-commons/src/main/java/org/apache/iotdb/commons/pipe/{extractor/IoTDBNonDataRegionExtractor.java
=> source/IoTDBNonDataRegionSource.java} (97%)
rename
iotdb-core/node-commons/src/main/java/org/apache/iotdb/commons/pipe/{extractor/IoTDBExtractor.java
=> source/IoTDBSource.java} (81%)
