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%)
