Package org.apache.hadoop.hbase.namequeues

Class WALEventTrackerQueueService

java.lang.Object

org.apache.hadoop.hbase.namequeues.WALEventTrackerQueueService

All Implemented Interfaces:

NamedQueueService

@Private
public class WALEventTrackerQueueService
extends Object
implements NamedQueueService

Field Summary

Fields

Modifier and Type	Field	Description
private static final org.slf4j.Logger	LOG
private org.apache.hbase.thirdparty.com.google.common.collect.EvictingQueue<WALEventTrackerPayload>	queue
private int	queueSize
private MetricsWALEventTrackerSource	source
private static final String	WAL_EVENT_TRACKER_RING_BUFFER_SIZE
private final boolean	walEventTrackerEnabled

Constructor Summary

Constructors

Constructor	Description
WALEventTrackerQueueService(org.apache.hadoop.conf.Configuration conf)
WALEventTrackerQueueService(org.apache.hadoop.conf.Configuration conf, MetricsWALEventTrackerSource source)

Method Summary

Modifier and Type	Method	Description
(package private) void	addToQueue(WALEventTrackerPayload payload)
boolean	clearNamedQueue()	Cleans up queues maintained by services.
void	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.
NamedQueuePayload.NamedQueueEvent	getEvent()	Retrieve event type for NamedQueueService implementation.
NamedQueueGetResponse	getNamedQueueRecords(NamedQueueGetRequest request)	Retrieve in memory queue records from ringbuffer
private Queue<WALEventTrackerPayload>	getWALEventTrackerList()
void	persistAll(Connection connection)	Add all in memory queue records to system table.

Methods inherited from class java.lang.Object

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

Field Details

queue

private org.apache.hbase.thirdparty.com.google.common.collect.EvictingQueue<WALEventTrackerPayload> queue

WAL_EVENT_TRACKER_RING_BUFFER_SIZE

private static final String WAL_EVENT_TRACKER_RING_BUFFER_SIZE

See Also:

• Constant Field Values

walEventTrackerEnabled

private final boolean walEventTrackerEnabled

queueSize

private int queueSize

source

private MetricsWALEventTrackerSource source

LOG

private static final org.slf4j.Logger LOG

Constructor Details

WALEventTrackerQueueService

public WALEventTrackerQueueService(org.apache.hadoop.conf.Configuration conf)

WALEventTrackerQueueService

public WALEventTrackerQueueService(org.apache.hadoop.conf.Configuration conf,
 MetricsWALEventTrackerSource source)

Method Details

getEvent

public NamedQueuePayload.NamedQueueEvent getEvent()

Description copied from interface: NamedQueueService

Retrieve event type for NamedQueueService implementation.

Specified by:

getEvent in interface NamedQueueService

Returns:

NamedQueuePayload.NamedQueueEvent

consumeEventFromDisruptor

public void consumeEventFromDisruptor(NamedQueuePayload namedQueuePayload)

Description copied from interface: NamedQueueService

This implementation is generic for consuming records from LMAX disruptor and inserts records to EvictingQueue which is maintained by each ringbuffer provider.

Specified by:

consumeEventFromDisruptor in interface NamedQueueService

Parameters:

namedQueuePayload - namedQueue payload from disruptor ring buffer

addToQueue

void addToQueue(WALEventTrackerPayload payload)

clearNamedQueue

public boolean clearNamedQueue()

Description copied from interface: NamedQueueService

Cleans up queues maintained by services.

Specified by:

clearNamedQueue in interface NamedQueueService

Returns:

true if slow log payloads are cleaned up, false otherwise

getNamedQueueRecords

public NamedQueueGetResponse getNamedQueueRecords(NamedQueueGetRequest request)

Description copied from interface: NamedQueueService

Retrieve in memory queue records from ringbuffer

Specified by:

getNamedQueueRecords in interface NamedQueueService

Parameters:

request - namedQueue request with event type

Returns:

queue records from ringbuffer after filter (if applied)

persistAll

public void persistAll(Connection connection)

Description copied from interface: NamedQueueService

Add all in memory queue records to system table. The implementors can use system table or direct HDFS file or ZK as persistence system.

Specified by:

persistAll in interface NamedQueueService

getWALEventTrackerList

private Queue<WALEventTrackerPayload> getWALEventTrackerList()