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 9978195d4b1 refactor PipeInclusionOptions
add fdb33fd6b2b refactor class name
No new revisions were added by this update.
Summary of changes:
.../PipeDataRegionConnectorConstructor.java | 22 ++++++++++++----------
.../client/IoTDBThriftAsyncClientManager.java | 4 ++--
.../IoTDBThriftSyncClientDataNodeManager.java | 3 +--
...tor.java => IoTDBDataRegionAsyncConnector.java} | 10 +++++-----
.../PipeTransferTabletBatchEventHandler.java | 7 ++++---
.../PipeTransferTabletInsertNodeEventHandler.java | 4 ++--
.../PipeTransferTabletInsertionEventHandler.java | 6 +++---
.../handler/PipeTransferTabletRawEventHandler.java | 4 ++--
.../PipeTransferTsFileInsertionEventHandler.java | 6 +++---
.../thrift/sync/IoTDBDataNodeSyncConnector.java | 2 ++
...ctor.java => IoTDBDataRegionSyncConnector.java} | 4 ++--
.../subtask/connector/PipeConnectorSubtask.java | 10 +++++-----
.../agent/plugin/PipePluginDataNodeAgentTest.java | 4 ++--
.../iotdb/db/pipe/connector/PipeConnectorTest.java | 12 ++++++------
14 files changed, 51 insertions(+), 47 deletions(-)
rename
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/connector/{protocol/thrift/sync
=> client}/IoTDBThriftSyncClientDataNodeManager.java (93%)
rename
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/connector/protocol/thrift/async/{IoTDBThriftAsyncConnector.java
=> IoTDBDataRegionAsyncConnector.java} (98%)
rename
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/connector/protocol/thrift/sync/{IoTDBThriftSyncConnector.java
=> IoTDBDataRegionSyncConnector.java} (99%)
