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 8d9c1a36ad8 Update PipeConfigNodeAgent.java
add 8c5b25eff1a refactor
No new revisions were added by this update.
Summary of changes:
.../statemachine/ConfigRegionStateMachine.java | 5 +-
.../agent/runtime/PipeConfigNodeRuntimeAgent.java | 28 ++++++--
.../agent/runtime/PipeConfigRegionListener.java | 75 ++++++++++++++++++++++
.../runtime/PipeConfigRegionStatusListener.java | 42 ------------
.../extractor/ConfigRegionListeningQueue.java | 51 ---------------
.../extractor/IoTDBConfigRegionExtractor.java | 3 +-
.../persistence/executor/ConfigPlanExecutor.java | 4 +-
.../confignode/persistence/pipe/PipeTaskInfo.java | 17 ++---
.../ConfigRegionListeningQueueTest.java | 19 +++---
.../agent/runtime/PipeDataNodeRuntimeAgent.java | 4 +-
...Listener.java => PipeSchemaRegionListener.java} | 2 +-
11 files changed, 122 insertions(+), 128 deletions(-)
create mode 100644
iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/manager/pipe/transfer/agent/runtime/PipeConfigRegionListener.java
delete mode 100644
iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/manager/pipe/transfer/agent/runtime/PipeConfigRegionStatusListener.java
rename
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/agent/runtime/{PipeSchemaRegionStatusListener.java
=> PipeSchemaRegionListener.java} (98%)
