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
