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