[iotdb] branch master updated (9acb3594a18 -> 80f9a80e50f)

[ro...@apache.org]

This is an automated email from the ASF dual-hosted git repository.

rong pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/iotdb.git


    from 9acb3594a18 Fix Region migrate bug (#10862)
     add 80f9a80e50f [IOTDB-6118] Pipe: Support transfer data through air gap (IoTDBAirGapConnector) (#10853)

No new revisions were added by this update.

Summary of changes:
 .../src/main/java/org/apache/iotdb/SSLClient.java  |   2 +-
 .../java/org/apache/iotdb/db/conf/IoTDBConfig.java |  22 +-
 .../db/pipe/agent/receiver/PipeReceiverAgent.java  |  70 ++---
 .../db/pipe/agent/runtime/PipeRuntimeAgent.java    |   6 +-
 .../config/constant/PipeConnectorConstant.java     |   4 +
 .../payload/airgap/AirGapOneByteResponse.java      |   7 +-
 .../airgap/AirGapPseudoTPipeTransferRequest.java   |   7 +-
 .../request/PipeTransferFilePieceReq.java          |  22 +-
 .../evolvable/request/PipeTransferFileSealReq.java |  22 +-
 .../request/PipeTransferHandshakeReq.java          |  20 +-
 .../request/PipeTransferInsertNodeReq.java         |  24 +-
 .../evolvable/request/PipeTransferTabletReq.java   | 111 ++++----
 ...TDBThriftConnector.java => IoTDBConnector.java} |   6 +-
 ...sion.java => IoTDBConnectorRequestVersion.java} |   6 +-
 .../protocol/airgap/IoTDBAirGapConnector.java      | 315 ++++++++++++++++++++-
 .../thrift/async/IoTDBThriftAsyncConnector.java    |   9 +-
 .../thrift/sync/IoTDBThriftSyncConnector.java      |  33 ++-
 .../pipe/receiver/airgap/IoTDBAirGapReceiver.java  | 180 +++++++++++-
 .../receiver/airgap/IoTDBAirGapReceiverAgent.java  |  97 +++++++
 ...iver.java => IoTDBLegacyPipeReceiverAgent.java} |  20 +-
 .../pipe/receiver/thrift/IoTDBThriftReceiver.java  |   4 +-
 .../thrift/IoTDBThriftReceiverAgent.java}          |  38 +--
 .../receiver/thrift/IoTDBThriftReceiverV1.java     |  22 +-
 .../connector/PipeConnectorSubtaskManager.java     |   4 +
 .../protocol/thrift/impl/ClientRPCServiceImpl.java |  14 +-
 .../java/org/apache/iotdb/db/service/DataNode.java |   4 +
 .../resources/conf/iotdb-common.properties         |   7 +
 .../iotdb/commons/concurrent/ThreadName.java       |   2 +
 .../apache/iotdb/commons/conf/CommonConfig.java    |  19 ++
 .../iotdb/commons/conf/CommonDescriptor.java       |  11 +
 .../iotdb/commons/pipe/config/PipeConfig.java      |  20 ++
 .../pipe/plugin/builtin/BuiltinPipePlugin.java     |   2 +
 ...yncConnector.java => IoTDBAirGapConnector.java} |   6 +-
 .../connector/IoTDBLegacyPipeConnector.java        |  54 +---
 .../builtin/connector/IoTDBThriftConnector.java    |  54 +---
 ...ipeConnector.java => PlaceholderConnector.java} |  12 +-
 .../apache/iotdb/commons/service/ServiceType.java  |   1 +
 .../org/apache/iotdb/tsfile/utils/BytesUtils.java  |   4 +-
 .../org/apache/iotdb/tsfile/utils/PublicBAOS.java  |   1 +
 pom.xml                                            |   1 -
 40 files changed, 909 insertions(+), 354 deletions(-)
 copy iotdb-api/pipe-api/src/main/java/org/apache/iotdb/pipe/api/customizer/configuration/PipeRuntimeConfiguration.java => iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/connector/payload/airgap/AirGapOneByteResponse.java (79%)
 copy iotdb-api/pipe-api/src/main/java/org/apache/iotdb/pipe/api/customizer/configuration/PipeRuntimeConfiguration.java => iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/connector/payload/airgap/AirGapPseudoTPipeTransferRequest.java (80%)
 rename iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/connector/protocol/{thrift/IoTDBThriftConnector.java => IoTDBConnector.java} (95%)
 rename iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/connector/protocol/{thrift/IoTDBThriftConnectorRequestVersion.java => IoTDBConnectorRequestVersion.java} (85%)
 create mode 100644 iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/receiver/airgap/IoTDBAirGapReceiverAgent.java
 rename iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/receiver/legacy/{IoTDBLegacyPipeReceiver.java => IoTDBLegacyPipeReceiverAgent.java} (96%)
 copy iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/{agent/receiver/PipeReceiverAgent.java => receiver/thrift/IoTDBThriftReceiverAgent.java} (68%)
 copy iotdb-core/node-commons/src/main/java/org/apache/iotdb/commons/pipe/plugin/builtin/connector/{IoTDBThriftSyncConnector.java => IoTDBAirGapConnector.java} (88%)
 copy iotdb-core/node-commons/src/main/java/org/apache/iotdb/commons/pipe/plugin/builtin/connector/{IoTDBLegacyPipeConnector.java => PlaceholderConnector.java} (86%)