(iotdb) branch pipe-meta-sync updated (e3ac993b3ba -> 21b46a8990a)

[ro...@apache.org]

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 e3ac993b3ba refactor
     add 21b46a8990a refactor

No new revisions were added by this update.

Summary of changes:
 .../statemachine/ConfigRegionStateMachine.java     |  7 +--
 .../runtime/PipeRuntimeCoordinator.java            |  4 +-
 .../pipe/transfer/agent/PipeConfigNodeAgent.java   | 50 +++++++++----------
 ...deAgent.java => PipeConfigNodePluginAgent.java} |  4 +-
 ...eAgent.java => PipeConfigNodeRuntimeAgent.java} | 21 +++++++-
 .../runtime/PipeConfigRegionStatusListener.java}   | 28 +++++------
 ...NodeAgent.java => PipeConfigNodeTaskAgent.java} |  6 +--
 .../extractor/ConfigRegionListeningQueue.java      |  2 +-
 .../confignode/persistence/pipe/PipeTaskInfo.java  |  6 +--
 .../ConfigRegionListeningQueueTest.java            |  3 +-
 .../schemaregion/SchemaRegionStateMachine.java     | 10 ++--
 .../org/apache/iotdb/db/pipe/agent/PipeAgent.java  | 56 +++++++++++-----------
 ...NodeAgent.java => PipeDataNodePluginAgent.java} | 22 ++++-----
 ...onAgent.java => PipeDataRegionPluginAgent.java} |  4 +-
 ...Agent.java => PipeSchemaRegionPluginAgent.java} |  4 +-
 ...erAgent.java => PipeDataNodeReceiverAgent.java} | 10 ++--
 ...odeAgent.java => PipeDataNodeRuntimeAgent.java} | 22 ++++++++-
 .../runtime/PipeSchemaRegionStatusListener.java    | 56 ++++++++++++++++++++++
 ...taNodeAgent.java => PipeDataNodeTaskAgent.java} | 10 ++--
 .../schemaregion/IoTDBSchemaRegionExtractor.java   |  5 +-
 .../schemaregion/SchemaRegionListeningQueue.java   |  2 +-
 ...tTest.java => PipeDataNodePluginAgentTest.java} |  4 +-
 .../extractor/SchemaRegionListeningQueueTest.java  |  4 +-
 .../listening/AbstractPipeListeningQueue.java      | 27 -----------
 24 files changed, 214 insertions(+), 153 deletions(-)
 rename iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/manager/pipe/transfer/agent/plugin/{PipePluginConfigNodeAgent.java => PipeConfigNodePluginAgent.java} (93%)
 rename iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/manager/pipe/transfer/agent/runtime/{PipeRuntimeConfigNodeAgent.java => PipeConfigNodeRuntimeAgent.java} (85%)
 copy iotdb-core/{node-commons/src/main/java/org/apache/iotdb/commons/pipe/task/DecoratingLock.java => confignode/src/main/java/org/apache/iotdb/confignode/manager/pipe/transfer/agent/runtime/PipeConfigRegionStatusListener.java} (60%)
 rename iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/manager/pipe/transfer/agent/task/{PipeTaskConfigNodeAgent.java => PipeConfigNodeTaskAgent.java} (94%)
 rename iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/agent/plugin/{PipePluginDataNodeAgent.java => PipeDataNodePluginAgent.java} (93%)
 rename iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/agent/plugin/dataregion/{PipePluginDataRegionAgent.java => PipeDataRegionPluginAgent.java} (93%)
 rename iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/agent/plugin/schemaregion/{PipePluginSchemaRegionAgent.java => PipeSchemaRegionPluginAgent.java} (93%)
 rename iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/agent/receiver/{PipeReceiverAgent.java => PipeDataNodeReceiverAgent.java} (91%)
 rename iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/agent/runtime/{PipeRuntimeDataNodeAgent.java => PipeDataNodeRuntimeAgent.java} (90%)
 create mode 100644 iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/agent/runtime/PipeSchemaRegionStatusListener.java
 rename iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/agent/task/{PipeTaskDataNodeAgent.java => PipeDataNodeTaskAgent.java} (98%)
 rename iotdb-core/datanode/src/test/java/org/apache/iotdb/db/pipe/agent/plugin/{PipePluginDataNodeAgentTest.java => PipeDataNodePluginAgentTest.java} (97%)