Package org.apache.hadoop.hbase.namequeues

Class RingBufferEnvelope

java.lang.Object

org.apache.hadoop.hbase.namequeues.RingBufferEnvelope

@Private
final class RingBufferEnvelope
extends Object

An envelope to carry payload in the ring buffer that serves as online buffer to provide latest events

Field Summary

Fields

Modifier and Type	Field	Description
private NamedQueuePayload	namedQueuePayload

Constructor Summary

Constructors

Constructor	Description
RingBufferEnvelope()

Method Summary

Modifier and Type	Method	Description
NamedQueuePayload	getPayload()	Retrieve current namedQueue payload NamedQueuePayload available on Envelope and free up the Envelope
void	load(NamedQueuePayload namedQueuePayload)	Load the Envelope with RpcCall

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Field Details

namedQueuePayload

private NamedQueuePayload namedQueuePayload

Constructor Details

RingBufferEnvelope

RingBufferEnvelope()

Method Details

load

public void load(NamedQueuePayload namedQueuePayload)

Load the Envelope with RpcCall

Parameters:

namedQueuePayload - all details of rpc call that would be useful for ring buffer consumers

getPayload

public NamedQueuePayload getPayload()

Retrieve current namedQueue payload NamedQueuePayload available on Envelope and free up the Envelope

Returns:

Retrieve rpc log details