You are viewing a plain text version of this content. The canonical link for it is here.

Posted to commits@iotdb.apache.org by ro...@apache.org on 2024/03/04 04:07:36 UTC

(iotdb) branch pipe-meta-sync updated (9978195d4b1 -> fdb33fd6b2b)

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