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 9cab08793f1 Pipe Meta: fixed the bug that cleared writeEvents'
reference counts can not be cleared (#12109)
add f30c8cc9d27 refactor
No new revisions were added by this update.
Summary of changes:
.../statemachine/ConfigRegionStateMachine.java | 12 +++++-----
.../runtime/PipeRuntimeCoordinator.java | 4 ++--
.../agent/task/PipeTaskConfigNodeAgent.java | 4 ++--
...ilter.java => ConfigRegionListeningFilter.java} | 16 ++++++-------
...gQueue.java => ConfigRegionListeningQueue.java} | 24 ++++++++++----------
.../extractor/IoTDBConfigRegionExtractor.java | 6 ++---
.../persistence/executor/ConfigPlanExecutor.java | 4 ++--
.../confignode/persistence/pipe/PipeTaskInfo.java | 16 ++++++-------
...st.java => ConfigRegionListeningQueueTest.java} | 26 +++++++++++-----------
.../schemaregion/SchemaExecutionVisitor.java | 4 ++--
.../schemaregion/SchemaRegionStateMachine.java | 14 ++++++------
.../db/pipe/agent/task/PipeTaskDataNodeAgent.java | 9 ++++----
.../dataregion/IoTDBDataRegionExtractor.java | 4 ++--
.../extractor/dataregion/PipeDataRegionFilter.java | 6 ++---
.../schemaregion/IoTDBSchemaRegionExtractor.java | 8 +++----
.../schemaregion/PipeSchemaNodeFilter.java | 6 ++---
...gQueue.java => SchemaRegionListeningQueue.java} | 24 ++++++++++----------
.../plan/node/pipe/PipeOperateSchemaQueueNode.java | 6 ++---
...st.java => SchemaRegionListeningQueueTest.java} | 26 +++++++++++-----------
.../PipeInclusionOptions.java} | 26 +++++++++++-----------
.../{ => queue}/ConcurrentIterableLinkedQueue.java | 2 +-
.../listening}/AbstractPipeListeningQueue.java | 5 +++--
.../AbstractSerializableListeningQueue.java | 22 +++++++++---------
.../serializer/PlainQueueSerializer.java | 4 ++--
.../{ => queue}/serializer/QueueSerializer.java | 4 ++--
.../serializer/QueueSerializerType.java} | 12 +++++-----
...TDBCommonExtractor.java => IoTDBExtractor.java} | 16 +++++++------
.../commons/pipe/extractor/IoTDBMetaExtractor.java | 6 ++---
.../ConcurrentIterableLinkedQueueTest.java | 2 ++
29 files changed, 163 insertions(+), 155 deletions(-)
rename
iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/manager/pipe/transfer/extractor/{PipeConfigPlanListeningFilter.java
=> ConfigRegionListeningFilter.java} (93%)
rename
iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/manager/pipe/transfer/extractor/{PipeConfigPlanListeningQueue.java
=> ConfigRegionListeningQueue.java} (86%)
rename
iotdb-core/confignode/src/test/java/org/apache/iotdb/confignode/persistence/{PipeConfigPlanListeningQueueTest.java
=> ConfigRegionListeningQueueTest.java} (79%)
rename
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/extractor/schemaregion/{SchemaNodeListeningQueue.java
=> SchemaRegionListeningQueue.java} (83%)
rename
iotdb-core/datanode/src/test/java/org/apache/iotdb/db/pipe/extractor/{SchemaNodeListeningQueueTest.java
=> SchemaRegionListeningQueueTest.java} (80%)
rename
iotdb-core/node-commons/src/main/java/org/apache/iotdb/commons/pipe/datastructure/{PipeInclusionNormalizer.java
=> options/PipeInclusionOptions.java} (91%)
rename
iotdb-core/node-commons/src/main/java/org/apache/iotdb/commons/pipe/datastructure/{
=> queue}/ConcurrentIterableLinkedQueue.java (99%)
rename
iotdb-core/node-commons/src/main/java/org/apache/iotdb/commons/pipe/datastructure/{
=> queue/listening}/AbstractPipeListeningQueue.java (97%)
rename
iotdb-core/node-commons/src/main/java/org/apache/iotdb/commons/pipe/datastructure/{
=> queue/listening}/AbstractSerializableListeningQueue.java (87%)
rename
iotdb-core/node-commons/src/main/java/org/apache/iotdb/commons/pipe/datastructure/{
=> queue}/serializer/PlainQueueSerializer.java (94%)
rename
iotdb-core/node-commons/src/main/java/org/apache/iotdb/commons/pipe/datastructure/{
=> queue}/serializer/QueueSerializer.java (89%)
rename
iotdb-core/node-commons/src/main/java/org/apache/iotdb/commons/pipe/datastructure/{LinkedQueueSerializerType.java
=> queue/serializer/QueueSerializerType.java} (74%)
rename
iotdb-core/node-commons/src/main/java/org/apache/iotdb/commons/pipe/extractor/{IoTDBCommonExtractor.java
=> IoTDBExtractor.java} (89%)
