Package | Description |
---|---|
org.apache.hadoop.hbase.namequeues |
Modifier and Type | Field and Description |
---|---|
private com.lmax.disruptor.dsl.Disruptor<RingBufferEnvelope> |
NamedQueueRecorder.disruptor |
Modifier and Type | Method and Description |
---|---|
void |
DisruptorExceptionHandler.handleEventException(Throwable e,
long sequence,
RingBufferEnvelope event) |
void |
LogEventHandler.onEvent(RingBufferEnvelope event,
long sequence,
boolean endOfBatch)
Called when a publisher has published an event to the
RingBuffer . |
Copyright © 2007–2020 The Apache Software Foundation. All rights reserved.