This is an automated email from the ASF dual-hosted git repository.
haonan pushed a change to branch ssl_between_nodes
in repository https://gitbox.apache.org/repos/asf/iotdb.git
from 470e58eb65a fix java.io.IOException: not connectable or finishConnect
returned false after we got an OP_CONNECT
add d2ee52ee14f [AINode] Remove remove-ainode scripts (#16023)
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 ac8642fa22f [AINode] Add cluster_ingress_port for AINodeWrapper
(#16043)
add 432e0273261 Pipe/Load: Implement multi-disk awareness of multiple file
systems during file copying and moving (#15356)
add 59199a269c1 fix estimating memory cost for string type (#16047)
add a3b24dace4e Implement builtin bitwise scalar functions in TableModel
add eacd3b74db6 Insert into query
add 2459e5211ce Change sort_buffer_size_in_bytes default value
add 9834d9031f7 Remove unnecessary synchronization for IoTConsensus
memeory management (#16049)
add 226fc6fd684 Pipe: Modify Sink Batch Metrics (#16018)
add 2113b5a171a Address NPE cause by topology service
add ee9d7d1b04e Fix concurrent modification of non-thread-safe data
structures caused by parallel dispatching
add 1d0b33ebafd Add strong password related configs (#15675)
add 75420adc79e Fix IoTDBTableAggregationQueryWithNetworkPartitionIT
add b8301077fb8 Revert default password to root (#16060)
add 88af0bc3b6b Fix wrong status code of case when
add 5138be01b18 Merge branch 'master' of github.com:apache/iotdb into
ssl_between_nodes
No new revisions were added by this update.
Summary of changes:
.github/workflows/daily-it.yml | 902 ++++++++++++++++++++-
.github/workflows/pipe-it.yml | 87 +-
README.md | 4 +-
README_ZH.md | 2 +-
example/odbc/README.md | 2 +-
.../it/env/cluster/config/MppCommonConfig.java | 6 +
.../it/env/cluster/config/MppConfigNodeConfig.java | 6 +
.../it/env/cluster/config/MppDataNodeConfig.java | 6 +
.../env/cluster/config/MppSharedCommonConfig.java | 7 +
.../iotdb/it/env/cluster/env/AbstractEnv.java | 9 +-
.../iotdb/it/env/cluster/node/AINodeWrapper.java | 19 +-
.../it/env/cluster/node/AbstractNodeWrapper.java | 53 +-
.../it/env/remote/config/RemoteCommonConfig.java | 6 +
.../env/remote/config/RemoteConfigNodeConfig.java | 5 +
.../it/env/remote/config/RemoteDataNodeConfig.java | 5 +
.../iotdb/it/env/remote/env/RemoteServerEnv.java | 2 +-
.../org/apache/iotdb/itbase/env/CommonConfig.java | 2 +
.../apache/iotdb/itbase/env/ConfigNodeConfig.java | 2 +
.../apache/iotdb/itbase/env/DataNodeConfig.java | 2 +
.../iotdb/ainode/it/AINodeInferenceSQLIT.java | 2 +-
.../confignode/it/IoTDBConfigNodeSnapshotIT.java | 2 +-
.../it/cluster/IoTDBClusterNodeGetterIT.java | 4 +-
.../it/database/IoTDBDatabaseSetAndDeleteIT.java | 6 +-
...oTDBMultiDBRegionGroupLeaderDistributionIT.java | 4 +
.../load/IoTDBRegionGroupLeaderDistributionIT.java | 16 +
.../IoTDBAutoRegionGroupExtension2IT.java | 3 +
.../partition/IoTDBAutoRegionGroupExtensionIT.java | 12 +-
.../it/partition/IoTDBPartitionCreationIT.java | 7 +
.../it/partition/IoTDBPartitionDurableIT.java | 13 +
.../it/partition/IoTDBPartitionGetterIT.java | 5 +-
.../confignode/it/procedure/IoTDBProcedureIT.java | 2 +-
...IoTDBRegionOperationReliabilityITFramework.java | 39 +-
.../IoTDBRegionGroupExpandAndShrinkForIoTV1IT.java | 3 +-
.../commit/IoTDBRegionReconstructForIoTV1IT.java | 104 ++-
.../IoTDBRegionMigrateWithLastEmptyDeletionIT.java | 101 +++
.../org/apache/iotdb/db/it/IoTDBEncodingIT.java | 4 +-
.../org/apache/iotdb/db/it/IoTDBExampleIT.java | 2 +-
.../apache/iotdb/db/it/IoTDBFloatPrecisionIT.java | 4 +-
.../org/apache/iotdb/db/it/IoTDBFlushQueryIT.java | 2 +-
.../apache/iotdb/db/it/IoTDBInsertWithQueryIT.java | 4 +-
.../org/apache/iotdb/db/it/IoTDBLoadTsFileIT.java | 37 +-
.../org/apache/iotdb/db/it/IoTDBMultiDeviceIT.java | 4 +-
.../org/apache/iotdb/db/it/IoTDBRestServiceIT.java | 83 +-
.../org/apache/iotdb/db/it/IoTDBRestartIT.java | 6 +-
.../apache/iotdb/db/it/IoTDBRestartRatisIT.java | 6 +-
.../it/IoTDBSameMeasurementsDifferentTypesIT.java | 2 +-
.../iotdb/db/it/IoTDBSetConfigurationIT.java | 4 +-
.../org/apache/iotdb/db/it/IoTDBSimpleQueryIT.java | 31 +-
.../db/it/IoTDBSyntaxConventionIdentifierIT.java | 17 +-
.../it/IoTDBSyntaxConventionStringLiteralIT.java | 19 +-
.../org/apache/iotdb/db/it/IoTDBTimeZoneIT.java | 2 +-
.../it/aggregation/IoTDBAggregationByLevelIT.java | 2 +-
.../aggregation/IoTDBAggregationSmallDataIT.java | 2 +-
.../db/it/aggregation/IoTDBTimeDurationIT.java | 30 +-
.../db/it/aligned/IoTDBInsertAlignedValuesIT.java | 2 +-
.../org/apache/iotdb/db/it/auth/IoTDBAuthIT.java | 309 +++++--
.../iotdb/db/it/auth/IoTDBClusterAuthorityIT.java | 5 +-
.../it/auth/IoTDBClusterAuthorityRelationalIT.java | 5 +-
.../iotdb/db/it/auth/IoTDBRelationalAuthIT.java | 33 +-
.../iotdb/db/it/auth/IoTDBSeriesPermissionIT.java | 86 +-
.../iotdb/db/it/auth/IoTDBSystemPermissionIT.java | 78 +-
.../db/it/auth/IoTDBTemplatePermissionIT.java | 39 +-
.../db/it/query/IoTDBEncryptionValueQueryIT.java | 16 +-
.../apache/iotdb/db/it/query/IoTDBQueryDemoIT.java | 16 +-
.../it/schema/IoTDBCreateAlignedTimeseriesIT.java | 2 +-
.../iotdb/db/it/schema/IoTDBCreateDatabaseIT.java | 2 +-
.../db/it/schema/IoTDBDeactivateTemplateIT.java | 6 +-
.../it/schema/IoTDBDeleteAlignedTimeseriesIT.java | 6 +-
.../iotdb/db/it/schema/IoTDBDeleteDatabaseIT.java | 10 +-
.../db/it/schema/IoTDBDeleteTimeSeriesIT.java | 8 +-
.../it/schema/IoTDBDisableAutoCreateSchemaIT.java | 4 +-
.../iotdb/db/it/schema/IoTDBExtendTemplateIT.java | 6 +-
.../iotdb/db/it/schema/IoTDBMetadataFetchIT.java | 22 +-
.../iotdb/db/it/schema/IoTDBSchemaTemplateIT.java | 6 +-
.../db/it/schema/IoTDBSortedShowTimeseriesIT.java | 117 +--
.../apache/iotdb/db/it/schema/IoTDBTagAlterIT.java | 20 +-
.../org/apache/iotdb/db/it/schema/IoTDBTagIT.java | 61 +-
.../apache/iotdb/db/it/schema/IoTDBTagLimitIT.java | 2 +-
.../schema/regionscan/IoTDBActiveRegionScanIT.java | 12 +-
.../IoTDBActiveRegionScanWithModsIT.java | 8 +-
.../regionscan/IoTDBActiveRegionScanWithTTLIT.java | 2 +-
.../regionscan/IoTDBActiveSchemaQueryIT.java | 13 +-
.../iotdb/db/it/selectinto/IoTDBSelectInto2IT.java | 1 +
.../iotdb/db/it/selectinto/IoTDBSelectInto3IT.java | 1 +
.../iotdb/db/it/selectinto/IoTDBSelectIntoIT.java | 9 +-
.../org/apache/iotdb/db/it/utils/TestUtils.java | 113 ++-
.../pipe/it/dual/tablemodel/TableModelUtils.java | 11 +-
.../manual/AbstractPipeTableModelDualManualIT.java | 4 +
.../tablemodel/manual/basic/IoTDBPipeAlterIT.java | 10 +
.../manual/basic/IoTDBPipeDataSinkIT.java | 45 +-
.../manual/basic/IoTDBPipeLifeCycleIT.java | 29 +-
.../manual/basic/IoTDBPipePermissionIT.java | 28 +-
...PipeExtractorIT.java => IoTDBPipeSourceIT.java} | 78 +-
.../manual/basic/IoTDBPipeSwitchStatusIT.java | 18 +
.../tablemodel/manual/basic/IoTDBPipeSyntaxIT.java | 10 +
.../manual/basic/IoTDBPipeWithLoadIT.java | 10 +-
.../manual/enhanced/IoTDBPipeClusterIT.java | 8 +-
.../manual/enhanced/IoTDBPipeDoubleLivingIT.java | 91 ++-
.../manual/enhanced/IoTDBPipeIdempotentIT.java | 22 +-
.../manual/enhanced/IoTDBPipeMetaIT.java | 36 +-
...sionIT.java => IoTDBPipeSinkCompressionIT.java} | 17 +-
...arallelIT.java => IoTDBPipeSinkParallelIT.java} | 7 +-
.../IoTDBPipeTypeConversionISessionIT.java | 7 +-
.../manual/enhanced/IoTDBPipeTypeConversionIT.java | 20 +-
.../auto/AbstractPipeDualTreeModelAutoIT.java | 10 +-
.../treemodel/auto/basic/IoTDBPipeAlterIT.java | 27 +-
.../treemodel/auto/basic/IoTDBPipeDataSinkIT.java | 50 +-
.../treemodel/auto/basic/IoTDBPipeLifeCycleIT.java | 292 ++++---
.../treemodel/auto/basic/IoTDBPipeProcessorIT.java | 8 +-
.../treemodel/auto/basic/IoTDBPipeProtocolIT.java | 44 +-
...arallelIT.java => IoTDBPipeSinkParallelIT.java} | 7 +-
...PipeExtractorIT.java => IoTDBPipeSourceIT.java} | 91 ++-
.../auto/basic/IoTDBPipeSwitchStatusIT.java | 22 +-
.../treemodel/auto/basic/IoTDBPipeSyntaxIT.java | 10 +
.../auto/basic/IoTDBTreePatternFormatIT.java | 18 +-
.../auto/enhanced/IoTDBPipeAutoConflictIT.java | 154 ++--
.../auto/enhanced/IoTDBPipeAutoDropIT.java | 11 +-
.../auto/enhanced/IoTDBPipeClusterIT.java | 129 ++-
.../enhanced/IoTDBPipeConditionalOperationsIT.java | 5 +
.../auto/enhanced/IoTDBPipeIdempotentIT.java | 72 +-
.../auto/enhanced/IoTDBPipeNullValueIT.java | 14 +-
...sionIT.java => IoTDBPipeSinkCompressionIT.java} | 21 +-
.../auto/enhanced/IoTDBPipeWithLoadIT.java | 23 +-
.../treemodel/auto/enhanced/PipeNowFunctionIT.java | 4 +
.../manual/AbstractPipeDualTreeModelManualIT.java | 4 +-
.../treemodel/manual/IoTDBPipeInclusionIT.java | 27 +-
.../manual/IoTDBPipeManualConflictIT.java | 34 +-
.../manual/IoTDBPipeMetaHistoricalIT.java | 33 +-
.../manual/IoTDBPipeMetaLeaderChangeIT.java | 14 +-
.../treemodel/manual/IoTDBPipeMetaRestartIT.java | 34 +-
.../manual/IoTDBPipeMultiSchemaRegionIT.java | 16 +-
.../treemodel/manual/IoTDBPipePermissionIT.java | 27 +-
.../treemodel/manual/IoTDBPipeReqAutoSliceIT.java | 4 +-
.../manual/IoTDBPipeTypeConversionISessionIT.java | 5 +-
.../manual/IoTDBPipeTypeConversionIT.java | 19 +-
.../iotdb/pipe/it/single/IoTDBPipeAggregateIT.java | 9 +-
.../iotdb/pipe/it/single/IoTDBPipeOPCUAIT.java | 13 +-
.../pipe/it/single/IoTDBPipePermissionIT.java | 20 +-
.../it/db/it/IoTDBAuthenticationTableIT.java | 41 +-
.../it/db/it/IoTDBCaseWhenThenTableIT.java | 4 +
.../relational/it/db/it/IoTDBRestartTableIT.java | 4 +-
.../relational/it/db/it/IoTDBWindowFunctionIT.java | 1 +
.../it/insertquery/IoTDBInsertQueryIT.java | 586 +++++++++++++
.../scalar/IoTDBBitwiseFunctionTableIT.java | 438 ++++++++++
.../it/query/recent/IoTDBMaintainAuthIT.java | 3 +-
.../it/query/recent/IoTDBNullIdQueryIT.java | 5 +-
.../it/query/recent/IoTDBQueryAuthIT.java | 3 +-
...ableAggregationQueryWithNetworkPartitionIT.java | 35 +-
.../view/recent/IoTDBNullIdQueryTableViewIT.java | 5 +-
.../relational/it/rest/it/IoTDBRestServiceIT.java | 1 +
.../it/rest/it/IoTDBRestServiceInsertValuesIT.java | 23 +
.../relational/it/schema/IoTDBDatabaseIT.java | 27 +-
.../iotdb/relational/it/schema/IoTDBTableIT.java | 23 +-
.../it/session/IoTDBSessionRelationalIT.java | 3 +
.../iotdb/session/it/IoTDBSessionComplexIT.java | 15 +-
.../session/it/IoTDBSessionSchemaTemplateIT.java | 4 +-
.../iotdb/session/it/IoTDBSessionSimpleIT.java | 4 +-
.../session/it/IoTDBSessionSyntaxConventionIT.java | 2 +-
.../it/dual/AbstractSubscriptionDualIT.java | 1 +
.../IoTDBSubscriptionConsumerGroupIT.java | 7 +-
.../IoTDBSubscriptionTimePrecisionIT.java | 2 +-
.../dual/treemodel/IoTDBSubscriptionTopicIT.java | 8 +-
.../tablemodel/IoTDBSubscriptionPermissionIT.java | 31 +-
.../it/triple/AbstractSubscriptionTripleIT.java | 5 +
.../AbstractSubscriptionTreeRegressionIT.java | 15 +-
...DBTestAutoCommitFalseDataSetPullConsumerIT.java | 39 +-
.../iotdb/tool/tsfile/ImportTsFileRemotely.java | 20 +-
.../client-py/tests/integration/iotdb_container.py | 5 +-
.../tests/integration/sqlalchemy/test_dialect.py | 19 +-
.../tests/integration/test_treemodel_insert.py | 3 +-
.../org/apache/iotdb/jdbc/IoTDBConnection.java | 2 +-
.../java/org/apache/iotdb/rpc/TSStatusCode.java | 1 +
.../apache/iotdb/session/util/SessionUtils.java | 9 +-
.../session/pool/SessionPoolExceptionTest.java | 2 +-
.../apache/iotdb/session/pool/SessionPoolTest.java | 2 +-
iotdb-core/ainode/ainode.xml | 9 -
.../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 ++
.../client/async/CnToDnAsyncRequestType.java | 3 +
.../CnToDnInternalServiceAsyncRequestManager.java | 5 +
.../confignode/conf/ConfigNodeDescriptor.java | 6 +-
.../confignode/conf/ConfigNodeStartupCheck.java | 5 +-
.../response/pipe/task/PipeTableResp.java | 2 +-
.../iotdb/confignode/manager/ConfigManager.java | 21 +-
.../confignode/manager/PermissionManager.java | 4 +
.../manager/load/balancer/RouteBalancer.java | 4 +
.../router/leader/AbstractLeaderBalancer.java | 1 +
.../balancer/router/leader/HashLeaderBalancer.java | 61 ++
.../confignode/manager/load/cache/LoadCache.java | 21 +-
.../load/cache/detector/PhiAccrualDetector.java | 33 +-
.../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 +-
.../iotdb/confignode/persistence/AuthorInfo.java | 18 +-
.../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 +-
.../thrift/ConfigNodeRPCServiceProcessor.java | 5 +
.../request/ConfigPhysicalPlanSerDeTest.java | 2 +-
.../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 +-
.../confignode/persistence/AuthorInfoTest.java | 16 +-
.../persistence/CNPhysicalPlanGeneratorTest.java | 6 +-
.../ConfigRegionListeningQueueTest.java | 2 +-
.../impl/sync/AuthOperationProcedureTest.java | 2 +-
.../common/request/IndexedConsensusRequest.java | 10 +
.../logdispatcher/IoTConsensusMemoryManager.java | 17 +
.../consensus/iot/logdispatcher/LogDispatcher.java | 18 +-
.../pipe/consensuspipe/ConsensusPipeManager.java | 32 +-
...usPipeConnector.java => ConsensusPipeSink.java} | 2 +-
.../pipe/metric/PipeConsensusSyncLagManager.java | 21 +-
.../org/apache/iotdb/db/auth/AuthorityChecker.java | 2 +-
.../iotdb/db/auth/ClusterAuthorityFetcher.java | 37 +
.../apache/iotdb/db/auth/IAuthorityFetcher.java | 3 +
.../java/org/apache/iotdb/db/conf/IoTDBConfig.java | 8 +-
.../org/apache/iotdb/db/conf/IoTDBDescriptor.java | 28 +-
.../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} | 91 ++-
.../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} | 167 ++--
.../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 | 80 +-
.../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 | 25 +-
.../evolvable/batch/PipeTabletEventPlainBatch.java | 21 +-
.../batch/PipeTabletEventTsFileBatch.java | 33 +-
.../batch/PipeTransferBatchReqBuilder.java | 89 +-
.../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} | 132 +--
.../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} | 97 ++-
.../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/client/ConfigNodeClient.java | 6 +
.../db/protocol/client/DataNodeInternalClient.java | 44 +
.../rest/table/v1/impl/RestApiServiceImpl.java | 136 ++--
.../iotdb/db/protocol/session/SessionManager.java | 142 +++-
.../iotdb/db/protocol/thrift/OperationType.java | 1 +
.../protocol/thrift/impl/ClientRPCServiceImpl.java | 5 +
.../impl/DataNodeInternalRPCServiceImpl.java | 22 +
.../db/queryengine/common/MPPQueryContext.java | 14 +-
.../operator/process/AbstractIntoOperator.java | 455 ++---------
.../operator/process/AbstractTreeIntoOperator.java | 146 ++++
.../operator/process/DeviceViewIntoOperator.java | 20 +-
.../process/InsertTabletStatementGenerator.java | 320 ++++++++
.../TableInsertTabletStatementGenerator.java | 134 +++
.../operator/process/TableIntoOperator.java | 178 ++++
.../TreeInsertTabletStatementGenerator.java | 119 +++
.../{IntoOperator.java => TreeIntoOperator.java} | 15 +-
.../relational/ColumnTransformerBuilder.java | 96 +++
.../iotdb/db/queryengine/plan/ClusterTopology.java | 30 +-
.../db/queryengine/plan/analyze/Analysis.java | 3 +-
.../queryengine/plan/analyze/AnalyzeVisitor.java | 4 +-
.../plan/analyze/ClusterPartitionFetcher.java | 9 +-
.../plan/analyze/IPartitionFetcher.java | 5 +
.../db/queryengine/plan/analyze/QueryType.java | 5 +-
.../analyze/cache/partition/PartitionCache.java | 108 ++-
.../plan/analyze/load/LoadTsFileAnalyzer.java | 88 +-
.../analyze/load/LoadTsFileTableSchemaCache.java | 17 +-
.../load/TreeSchemaAutoCreatorAndVerifier.java | 30 +-
.../analyze/schema/ClusterSchemaFetchExecutor.java | 3 +-
.../plan/analyze/schema/ClusterSchemaFetcher.java | 8 +-
.../plan/analyze/schema/NormalSchemaFetcher.java | 29 +-
.../plan/execution/IQueryExecution.java | 3 +
.../queryengine/plan/execution/QueryExecution.java | 9 +-
.../plan/execution/config/ConfigExecution.java | 7 +-
.../execution/config/TableConfigTaskVisitor.java | 71 +-
.../execution/config/TreeConfigTaskVisitor.java | 16 +
.../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/planner/OperatorGeneratorUtil.java | 78 ++
.../plan/planner/OperatorTreeGenerator.java | 49 +-
.../plan/planner/TableOperatorGenerator.java | 63 ++
.../planner/distribution/DistributionPlanner.java | 5 +-
.../plan/AbstractFragmentParallelPlanner.java | 2 +-
.../plan/planner/plan/node/PlanGraphPrinter.java | 10 +
.../plan/planner/plan/node/PlanNodeType.java | 4 +
.../plan/planner/plan/node/PlanVisitor.java | 5 +
.../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 +-
.../plan/relational/analyzer/Analysis.java | 29 +
.../relational/analyzer/StatementAnalyzer.java | 117 ++-
.../relational/metadata/TableMetadataImpl.java | 41 +
.../plan/relational/metadata/TableSchema.java | 23 +
.../plan/relational/planner/IrTypeAnalyzer.java | 30 +-
.../plan/relational/planner/QueryPlanner.java | 10 +
.../relational/planner/TableLogicalPlanner.java | 99 +++
.../distribute/TableDistributedPlanGenerator.java | 67 ++
.../distribute/TableDistributedPlanner.java | 5 +-
.../TableModelTypeProviderExtractor.java | 15 +
.../plan/relational/planner/node/IntoNode.java | 173 ++++
.../optimizations/UnaliasSymbolReferences.java | 10 +
.../plan/relational/sql/ast/Insert.java | 7 +
.../sql/ast/RelationalAuthorStatement.java | 47 ++
.../plan/relational/sql/parser/AstBuilder.java | 5 +-
.../plan/scheduler/ClusterScheduler.java | 8 +-
.../scheduler/FragmentInstanceDispatcherImpl.java | 15 +-
.../plan/statement/crud/InsertBaseStatement.java | 19 +
.../plan/statement/sys/AuthorStatement.java | 37 +
.../scalar/AbstractBitwise2ColumnTransformer.java | 71 ++
.../scalar/AbstractBitwiseColumnTransformer.java | 62 ++
.../unary/scalar/BitCount2ColumnTransformer.java | 76 ++
.../unary/scalar/BitCountColumnTransformer.java | 68 ++
.../unary/scalar/BitwiseAnd2ColumnTransformer.java | 44 +
.../unary/scalar/BitwiseAndColumnTransformer.java | 42 +
.../scalar/BitwiseLeftShift2ColumnTransformer.java | 60 ++
.../scalar/BitwiseLeftShiftColumnTransformer.java | 47 ++
.../unary/scalar/BitwiseNotColumnTransformer.java | 63 ++
.../unary/scalar/BitwiseOr2ColumnTransformer.java | 44 +
.../unary/scalar/BitwiseOrColumnTransformer.java | 42 +
.../BitwiseRightShift2ColumnTransformer.java | 60 ++
...wiseRightShiftArithmetic2ColumnTransformer.java | 65 ++
...twiseRightShiftArithmeticColumnTransformer.java | 49 ++
.../scalar/BitwiseRightShiftColumnTransformer.java | 47 ++
.../unary/scalar/BitwiseXor2ColumnTransformer.java | 44 +
.../unary/scalar/BitwiseXorColumnTransformer.java | 42 +
.../transformation/dag/util/BitwiseUtils.java | 210 +++++
.../db/storageengine/dataregion/DataRegion.java | 95 ++-
.../estimator/CompactionEstimateUtils.java | 5 +
.../dataregion/memtable/TsFileProcessor.java | 7 +-
.../load/active/ActiveLoadDirScanner.java | 1 +
.../storageengine/load/active/ActiveLoadUtil.java | 183 +++++
...leStatementDataTypeConvertExecutionVisitor.java | 2 +-
...eeStatementDataTypeConvertExecutionVisitor.java | 2 +-
.../converter/LoadTsFileDataTypeConverter.java | 81 +-
.../storageengine/load/disk/ILoadDiskSelector.java | 36 +-
.../InheritSystemMultiDisksStrategySelector.java | 50 +-
.../db/storageengine/load/disk/MinIOSelector.java | 62 +-
.../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 +-
.../apache/iotdb/db/utils/DataNodeAuthUtils.java | 184 +++++
.../iotdb/db/auth/AuthorizerManagerTest.java | 2 +-
.../auth/authorizer/LocalFileAuthorizerTest.java | 16 +-
.../org/apache/iotdb/db/auth/entity/UserTest.java | 2 +-
.../db/auth/user/LocalFileUserAccessorTest.java | 4 +-
.../db/auth/user/LocalFileUserManagerTest.java | 2 +-
.../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 +-
.../operator/MergeTreeSortOperatorTest.java | 8 +-
.../execution/operator/OperatorMemoryTest.java | 46 +-
.../planner/node/process/IntoNodeSerdeTest.java | 38 +
.../plan/relational/analyzer/AnalyzerTest.java | 5 +-
.../relational/analyzer/InsertIntoQueryTest.java | 122 +++
.../plan/relational/analyzer/TestMetadata.java | 7 +-
.../transformation/dag/util/BitwiseUtilsTest.java | 131 +++
.../security/encrypt/MessageDigestEncryptTest.java | 2 +-
.../iotdb/metrics/config/MetricConfigTest.java | 8 +-
.../resources/conf/iotdb-system.properties | 1 +
.../conf/iotdb-system.properties.template | 6 +-
.../iotdb/commons/auth/user/BasicUserManager.java | 17 +-
.../apache/iotdb/commons/conf/CommonConfig.java | 78 +-
...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 +-
.../pipe/config/constant/SystemConstant.java | 3 +
...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} | 217 ++---
.../protocol/IoTDBSslSyncSink.java} | 30 +-
.../IoTDBNonDataRegionSource.java} | 10 +-
.../IoTDBSource.java} | 58 +-
.../schema/column/ColumnHeaderConstant.java | 8 +-
.../commons/subscription/meta/topic/TopicMeta.java | 6 +-
.../relational/TableBuiltinScalarFunction.java | 8 +
.../org/apache/iotdb/commons/utils/AuthUtils.java | 87 +-
.../iotdb/commons/utils/CommonDateTimeUtils.java | 12 +
.../exception/pipe/PipeRuntimeExceptionTest.java | 9 +-
.../pipe/plugin/builtin/BuiltinPipePluginTest.java | 16 +-
.../iotdb/commons/pipe/task/PipeMetaDeSerTest.java | 4 +-
.../apache/iotdb/commons/utils/AuthUtilsTest.java | 18 +-
.../src/main/thrift/confignode.thrift | 2 +
.../src/main/thrift/datanode.thrift | 4 +
pom.xml | 2 +-
scripts/tools/ops/remove-ainode.sh | 111 ---
scripts/tools/windows/ops/remove-ainode.bat | 107 ---
666 files changed, 12793 insertions(+), 5854 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} (96%)
rename
integration-test/src/test/java/org/apache/iotdb/pipe/it/dual/tablemodel/manual/enhanced/{IoTDBPipeConnectorCompressionIT.java
=> IoTDBPipeSinkCompressionIT.java} (96%)
rename
integration-test/src/test/java/org/apache/iotdb/pipe/it/dual/tablemodel/manual/enhanced/{IoTDBPipeConnectorParallelIT.java
=> IoTDBPipeSinkParallelIT.java} (96%)
rename
integration-test/src/test/java/org/apache/iotdb/pipe/it/dual/treemodel/auto/basic/{IoTDBPipeConnectorParallelIT.java
=> IoTDBPipeSinkParallelIT.java} (94%)
rename
integration-test/src/test/java/org/apache/iotdb/pipe/it/dual/treemodel/auto/basic/{IoTDBPipeExtractorIT.java
=> IoTDBPipeSourceIT.java} (95%)
rename
integration-test/src/test/java/org/apache/iotdb/pipe/it/dual/treemodel/auto/enhanced/{IoTDBPipeConnectorCompressionIT.java
=> IoTDBPipeSinkCompressionIT.java} (96%)
create mode 100644
integration-test/src/test/java/org/apache/iotdb/relational/it/insertquery/IoTDBInsertQueryIT.java
create mode 100644
integration-test/src/test/java/org/apache/iotdb/relational/it/query/old/builtinfunction/scalar/IoTDBBitwiseFunctionTableIT.java
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
create mode 100644
iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/manager/load/balancer/router/leader/HashLeaderBalancer.java
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} (78%)
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} (76%)
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 (91%)
rename iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/{connector
=> sink}/payload/evolvable/batch/PipeTabletEventPlainBatch.java (92%)
rename iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/{connector
=> sink}/payload/evolvable/batch/PipeTabletEventTsFileBatch.java (88%)
rename iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/{connector
=> sink}/payload/evolvable/batch/PipeTransferBatchReqBuilder.java (72%)
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} (87%)
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} (87%)
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%)
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/execution/operator/process/AbstractTreeIntoOperator.java
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/execution/operator/process/InsertTabletStatementGenerator.java
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/execution/operator/process/TableInsertTabletStatementGenerator.java
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/execution/operator/process/TableIntoOperator.java
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/execution/operator/process/TreeInsertTabletStatementGenerator.java
rename
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/execution/operator/process/{IntoOperator.java
=> TreeIntoOperator.java} (92%)
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/planner/OperatorGeneratorUtil.java
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/relational/planner/node/IntoNode.java
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/transformation/dag/column/unary/scalar/AbstractBitwise2ColumnTransformer.java
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/transformation/dag/column/unary/scalar/AbstractBitwiseColumnTransformer.java
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/transformation/dag/column/unary/scalar/BitCount2ColumnTransformer.java
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/transformation/dag/column/unary/scalar/BitCountColumnTransformer.java
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/transformation/dag/column/unary/scalar/BitwiseAnd2ColumnTransformer.java
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/transformation/dag/column/unary/scalar/BitwiseAndColumnTransformer.java
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/transformation/dag/column/unary/scalar/BitwiseLeftShift2ColumnTransformer.java
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/transformation/dag/column/unary/scalar/BitwiseLeftShiftColumnTransformer.java
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/transformation/dag/column/unary/scalar/BitwiseNotColumnTransformer.java
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/transformation/dag/column/unary/scalar/BitwiseOr2ColumnTransformer.java
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/transformation/dag/column/unary/scalar/BitwiseOrColumnTransformer.java
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/transformation/dag/column/unary/scalar/BitwiseRightShift2ColumnTransformer.java
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/transformation/dag/column/unary/scalar/BitwiseRightShiftArithmetic2ColumnTransformer.java
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/transformation/dag/column/unary/scalar/BitwiseRightShiftArithmeticColumnTransformer.java
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/transformation/dag/column/unary/scalar/BitwiseRightShiftColumnTransformer.java
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/transformation/dag/column/unary/scalar/BitwiseXor2ColumnTransformer.java
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/transformation/dag/column/unary/scalar/BitwiseXorColumnTransformer.java
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/transformation/dag/util/BitwiseUtils.java
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/storageengine/load/active/ActiveLoadUtil.java
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%)
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/utils/DataNodeAuthUtils.java
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%)
create mode 100644
iotdb-core/datanode/src/test/java/org/apache/iotdb/db/queryengine/plan/relational/analyzer/InsertIntoQueryTest.java
create mode 100644
iotdb-core/datanode/src/test/java/org/apache/iotdb/db/queryengine/transformation/dag/util/BitwiseUtilsTest.java
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%)
delete mode 100755 scripts/tools/ops/remove-ainode.sh
delete mode 100644 scripts/tools/windows/ops/remove-ainode.bat
