[MINOR][RFC-53] Fix typos (#5764)
Co-authored-by: yuezhang <yuezhang@freewheel.tv>
This commit is contained in:
@@ -92,7 +92,7 @@ The Disruptor is a library that provides a concurrent ring buffer data structure
|
||||
We use the Disruptor multi-producer single-consumer working model:
|
||||
- Define `DisruptorPublisher` to register producers into Disruptor and control the produce behaviors including life cycle.
|
||||
- Define `DisruptorMessageHandler` to register consumers into Disruptor and write consumption data from disruptor to hudi data file.
|
||||
For example we will clear clear out the event after processing it to avoid to avoid unnecessary memory and GC pressure
|
||||
For example we will clear out the event after processing it to avoid unnecessary memory and GC pressure
|
||||
- Define `HoodieDisruptorEvent` as the carrier of the hoodie message
|
||||
- Define `HoodieDisruptorEventFactory`: Pre-populate all the hoodie events to fill the RingBuffer.
|
||||
We can use `HoodieDisruptorEventFactory` to create `HoodieDisruptorEvent` storing the data for sharing during exchange or parallel coordination of an event.
|
||||
|
||||
Reference in New Issue
Block a user