Skip to content

Commit deff732

Browse files
committed
spotless
1 parent d41db94 commit deff732

5 files changed

Lines changed: 8 additions & 6 deletions

File tree

iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/source/dataregion/realtime/disruptor/Disruptor.java

Lines changed: 1 addition & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -31,6 +31,7 @@
3131
* and simplified for IoTDB's specific use case in the Pipe module.
3232
*
3333
* <p>Key simplifications:
34+
*
3435
* <ul>
3536
* <li>Single event handler support (no complex dependency graphs)
3637
* <li>Simplified lifecycle management

iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/source/dataregion/realtime/disruptor/EventFactory.java

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -22,8 +22,8 @@
2222
/**
2323
* Event factory for pre-allocating events in RingBuffer
2424
*
25-
* <p>This interface is based on LMAX Disruptor (https://github.com/LMAX-Exchange/disruptor)
26-
* and adapted for IoTDB's Pipe module.
25+
* <p>This interface is based on LMAX Disruptor (https://github.com/LMAX-Exchange/disruptor) and
26+
* adapted for IoTDB's Pipe module.
2727
*
2828
* @param <T> event type
2929
*/

iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/source/dataregion/realtime/disruptor/EventHandler.java

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -22,8 +22,8 @@
2222
/**
2323
* Event handler for processing events from RingBuffer
2424
*
25-
* <p>This interface is based on LMAX Disruptor (https://github.com/LMAX-Exchange/disruptor)
26-
* and adapted for IoTDB's Pipe module.
25+
* <p>This interface is based on LMAX Disruptor (https://github.com/LMAX-Exchange/disruptor) and
26+
* adapted for IoTDB's Pipe module.
2727
*
2828
* @param <T> event type
2929
*/

iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/source/dataregion/realtime/disruptor/ExceptionHandler.java

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -22,8 +22,8 @@
2222
/**
2323
* Exception handler for event processing errors
2424
*
25-
* <p>This interface is based on LMAX Disruptor (https://github.com/LMAX-Exchange/disruptor)
26-
* and adapted for IoTDB's Pipe module.
25+
* <p>This interface is based on LMAX Disruptor (https://github.com/LMAX-Exchange/disruptor) and
26+
* adapted for IoTDB's Pipe module.
2727
*
2828
* @param <T> event type
2929
*/

iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/source/dataregion/realtime/disruptor/MultiProducerSequencer.java

Lines changed: 1 addition & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -29,6 +29,7 @@
2929
* and preserves the core lock-free multi-producer algorithm for IoTDB's Pipe module.
3030
*
3131
* <p>Key features preserved from LMAX Disruptor:
32+
*
3233
* <ul>
3334
* <li>Lock-free CAS-based sequence claiming
3435
* <li>Availability buffer for out-of-order publishing detection

0 commit comments

Comments
 (0)