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 9ece9666f94 refactor
add ba1b8a87b12 refactor
add bea86d58458 refactor
add d421082975a refactor
add 7d98af69f84 SchemaRegionListeningQueue
add fad5ee8010c refactor
No new revisions were added by this update.
Summary of changes:
.../extractor/ConfigRegionListeningFilter.java | 2 +
.../extractor/ConfigRegionListeningQueue.java | 32 +++++---
.../extractor/IoTDBConfigRegionExtractor.java | 9 ++-
.../db/pipe/agent/task/PipeTaskDataNodeAgent.java | 5 +-
.../schemaregion/IoTDBSchemaRegionExtractor.java | 23 +++---
.../schemaregion/SchemaRegionListeningFilter.java | 2 +-
.../schemaregion/SchemaRegionListeningQueue.java | 25 +++---
.../queue/ConcurrentIterableLinkedQueue.java | 15 ++++
.../listening/AbstractPipeListeningQueue.java | 74 ++++++++++-------
.../AbstractSerializableListeningQueue.java | 92 ++++++++++++----------
.../commons/pipe/extractor/IoTDBExtractor.java | 1 +
.../extractor/IoTDBNonDataRegionExtractor.java | 91 +++++++++++----------
12 files changed, 215 insertions(+), 156 deletions(-)
