[iotdb] branch master updated (e39060e1d1 -> 299f33c80c)

[ro...@apache.org]

This is an automated email from the ASF dual-hosted git repository.

rong pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/iotdb.git


    from e39060e1d1 update ratis version to 2.5.1 (#9785)
     add 299f33c80c [IOTDB-5821] Pipe: PipeCollector Stage (#9789)

No new revisions were added by this update.

Summary of changes:
 .../iotdb/commons/consensus/DataRegionId.java      |  4 --
 .../pipe/plugin/builtin/BuiltinPipePlugin.java     |  8 ++-
 .../plugin/builtin/collector/DefaultCollector.java | 60 ++++++++++++++++
 .../db/pipe/agent/plugin/PipePluginAgent.java      |  7 ++
 .../db/pipe/config/PipeCollectorConstant.java      | 16 ++---
 .../core/collector/IoTDBDataRegionCollector.java   | 84 ++++++++++++++++++++++
 ...> PipeHistoricalDataRegionTsFileCollector.java} | 39 +++++-----
 .../realtime/PipeRealtimeDataRegionCollector.java  | 21 +++---
 ... => PipeRealtimeDataRegionHybridCollector.java} | 13 ++--
 .../db/pipe/task/stage/PipeTaskCollectorStage.java | 34 +++++----
 .../collector/CachedSchemaPatternMatcherTest.java  | 48 ++++++++++---
 .../core/collector/PipeRealtimeCollectTest.java    | 58 ++++++++++++---
 12 files changed, 305 insertions(+), 87 deletions(-)
 create mode 100644 node-commons/src/main/java/org/apache/iotdb/commons/pipe/plugin/builtin/collector/DefaultCollector.java
 copy integration-test/src/main/java/org/apache/iotdb/it/env/EnvType.java => server/src/main/java/org/apache/iotdb/db/pipe/config/PipeCollectorConstant.java (72%)
 create mode 100644 server/src/main/java/org/apache/iotdb/db/pipe/core/collector/IoTDBDataRegionCollector.java
 rename server/src/main/java/org/apache/iotdb/db/pipe/core/collector/historical/{PipeHistoricalTsFileCollector.java => PipeHistoricalDataRegionTsFileCollector.java} (76%)
 rename server/src/main/java/org/apache/iotdb/db/pipe/core/collector/realtime/{PipeRealtimeHybridDataRegionCollector.java => PipeRealtimeDataRegionHybridCollector.java} (95%)