Package | Description |
---|---|
org.apache.hadoop.hbase.namequeues | |
org.apache.hadoop.hbase.namequeues.impl |
Modifier and Type | Class and Description |
---|---|
class |
BalancerDecisionDetails
Balancer decision details that would be passed on to ring buffer for history
|
class |
BalancerRejectionDetails
Balancer rejection details that would be passed on to ring buffer for history
|
class |
RpcLogDetails
RpcCall details that would be passed on to ring buffer of slow log responses
|
Modifier and Type | Field and Description |
---|---|
private NamedQueuePayload |
RingBufferEnvelope.namedQueuePayload |
Modifier and Type | Method and Description |
---|---|
NamedQueuePayload |
RingBufferEnvelope.getPayload()
Retrieve current namedQueue payload
NamedQueuePayload available on Envelope and free up
the Envelope |
Modifier and Type | Method and Description |
---|---|
void |
NamedQueueRecorder.addRecord(NamedQueuePayload namedQueuePayload)
Add various NamedQueue records to ringbuffer.
|
void |
NamedQueueService.consumeEventFromDisruptor(NamedQueuePayload namedQueuePayload)
This implementation is generic for consuming records from LMAX disruptor and inserts records to
EvictingQueue which is maintained by each ringbuffer provider.
|
void |
RingBufferEnvelope.load(NamedQueuePayload namedQueuePayload)
Load the Envelope with
RpcCall |
Modifier and Type | Method and Description |
---|---|
void |
BalancerRejectionQueueService.consumeEventFromDisruptor(NamedQueuePayload namedQueuePayload) |
void |
SlowLogQueueService.consumeEventFromDisruptor(NamedQueuePayload namedQueuePayload)
This implementation is specific to slowLog event.
|
void |
BalancerDecisionQueueService.consumeEventFromDisruptor(NamedQueuePayload namedQueuePayload) |
Copyright © 2007–2020 The Apache Software Foundation. All rights reserved.