You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@iotdb.apache.org by ju...@apache.org on 2025/10/23 09:16:08 UTC
(iotdb) branch master updated (9b0e48f2f42 -> a429dfcb3b6)

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

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


    from 9b0e48f2f42 Pipe: Fixed the shouldMarkAsPipeRequest for CreateTable and AlterLogicalView Sync (#16619)
     add a429dfcb3b6 Pipe: Implementing DisruptorQueue (#16639)

No new revisions were added by this update.

Summary of changes:
 LICENSE                                            |  10 +
 dependencies.json                                  |   1 -
 iotdb-core/datanode/pom.xml                        |   4 -
 .../event/common/heartbeat/PipeHeartbeatEvent.java |   4 +-
 .../realtime/assigner/DisruptorQueue.java          |  16 +-
 .../assigner/DisruptorQueueExceptionHandler.java   |   3 +-
 .../realtime/disruptor/BatchEventProcessor.java    | 120 +++++++++
 .../dataregion/realtime/disruptor/Disruptor.java   | 135 ++++++++++
 .../realtime/disruptor/EventFactory.java}          |  26 +-
 .../realtime/disruptor/EventHandler.java}          |  27 +-
 .../realtime/disruptor/ExceptionHandler.java}      |  39 +--
 .../realtime/disruptor/MultiProducerSequencer.java | 259 ++++++++++++++++++
 .../dataregion/realtime/disruptor/RingBuffer.java  | 295 +++++++++++++++++++++
 .../dataregion/realtime/disruptor/Sequence.java    | 122 +++++++++
 .../realtime/disruptor/SequenceBarrier.java        |  78 ++++++
 .../realtime/disruptor/SequenceGroups.java         |  77 ++++++
 pom.xml                                            |   6 -
 17 files changed, 1159 insertions(+), 63 deletions(-)
 create mode 100644 iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/source/dataregion/realtime/disruptor/BatchEventProcessor.java
 create mode 100644 iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/source/dataregion/realtime/disruptor/Disruptor.java
 copy iotdb-core/datanode/src/main/java/org/apache/iotdb/db/{storageengine/dataregion/compaction/selector/estimator/IFileQueryMemMeasurement.java => pipe/source/dataregion/realtime/disruptor/EventFactory.java} (66%)
 copy iotdb-core/{node-commons/src/main/java/org/apache/iotdb/commons/pipe/agent/task/connection/EventSupplier.java => datanode/src/main/java/org/apache/iotdb/db/pipe/source/dataregion/realtime/disruptor/EventHandler.java} (58%)
 copy iotdb-core/{node-commons/src/main/java/org/apache/iotdb/commons/exception/StartupException.java => datanode/src/main/java/org/apache/iotdb/db/pipe/source/dataregion/realtime/disruptor/ExceptionHandler.java} (55%)
 create mode 100644 iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/source/dataregion/realtime/disruptor/MultiProducerSequencer.java
 create mode 100644 iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/source/dataregion/realtime/disruptor/RingBuffer.java
 create mode 100644 iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/source/dataregion/realtime/disruptor/Sequence.java
 create mode 100644 iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/source/dataregion/realtime/disruptor/SequenceBarrier.java
 create mode 100644 iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/source/dataregion/realtime/disruptor/SequenceGroups.java