This is an automated email from the ASF dual-hosted git repository.
rong pushed a change to branch pipe-meta-sync
in repository https://gitbox.apache.org/repos/asf/iotdb.git
from 56126303347 refactor connector
add 9df0a75b74f refactor
add c812a30c537 fix airgap handshake
add 3fedc2ea244 Update IoTDBConfigRegionAirGapConnector.java
No new revisions were added by this update.
Summary of changes:
....java => IoTDBConfigNodeSyncClientManager.java} | 8 +--
.../config/IoTDBConfigRegionAirGapConnector.java | 19 ++++++-
.../config/IoTDBConfigRegionConnector.java | 15 +++---
...r.java => IoTDBDataNodeAsyncClientManager.java} | 9 ++--
.../IoTDBDataNodeCacheLeaderClientManager.java | 6 +--
...er.java => IoTDBDataNodeSyncClientManager.java} | 42 +++++++++++----
.../IoTDBThriftLeaderCacheClientManager.java | 37 -------------
.../IoTDBThriftSyncClientDataNodeManager.java | 60 ----------------------
.../airgap/IoTDBDataNodeAirGapConnector.java | 19 ++++++-
.../protocol/legacy/IoTDBLegacyPipeConnector.java | 6 +--
.../async/IoTDBDataRegionAsyncConnector.java | 6 +--
.../thrift/sync/IoTDBDataNodeSyncConnector.java | 18 ++++---
.../thrift/sync/IoTDBDataRegionSyncConnector.java | 26 ++++------
.../thrift/sync/IoTDBSchemaRegionConnector.java | 4 +-
...tClientManager.java => IoTDBClientManager.java} | 8 +--
...ncConnectorClient.java => IoTDBSyncClient.java} | 4 +-
...entManager.java => IoTDBSyncClientManager.java} | 42 +++++++--------
.../connector/protocol/IoTDBAirGapConnector.java | 15 ++++--
.../connector/protocol/IoTDBSslSyncConnector.java | 6 +--
19 files changed, 159 insertions(+), 191 deletions(-)
rename
iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/manager/pipe/transfer/connector/client/{IoTDBThriftSyncClientConfigNodeManager.java
=> IoTDBConfigNodeSyncClientManager.java} (88%)
rename
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/connector/client/{IoTDBThriftAsyncClientManager.java
=> IoTDBDataNodeAsyncClientManager.java} (95%)
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/client/IoTDBDataNodeCacheLeaderClientManager.java
(82%)
rename
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/connector/client/{IoTDBThriftSyncLeaderCacheClientManager.java
=> IoTDBDataNodeSyncClientManager.java} (58%)
delete mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/connector/client/IoTDBThriftLeaderCacheClientManager.java
delete mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/connector/client/IoTDBThriftSyncClientDataNodeManager.java
rename
iotdb-core/node-commons/src/main/java/org/apache/iotdb/commons/pipe/connector/client/{IoTDBThriftClientManager.java
=> IoTDBClientManager.java} (83%)
rename
iotdb-core/node-commons/src/main/java/org/apache/iotdb/commons/pipe/connector/client/{IoTDBThriftSyncConnectorClient.java
=> IoTDBSyncClient.java} (95%)
rename
iotdb-core/node-commons/src/main/java/org/apache/iotdb/commons/pipe/connector/client/{IoTDBThriftSyncClientManager.java
=> IoTDBSyncClientManager.java} (84%)
