org.apache.hadoop.hbase.replication.regionserver

Class ReplicationSourceLogQueue

java.lang.Object

org.apache.hadoop.hbase.replication.regionserver.ReplicationSourceLogQueue

@InterfaceAudience.Private
 @InterfaceStability.Evolving
public class ReplicationSourceLogQueue
extends Object

Field Summary

Fields

Modifier and Type	Field and Description
private org.apache.hadoop.conf.Configuration	conf
private static org.slf4j.Logger	LOG
private int	logQueueWarnThreshold
private MetricsSource	metrics
private Map<String,PriorityBlockingQueue<org.apache.hadoop.fs.Path>>	queues
private int	queueSizePerGroup
private ReplicationSource	source

Constructor Summary

Constructors

Constructor and Description
ReplicationSourceLogQueue(org.apache.hadoop.conf.Configuration conf, MetricsSource metrics, ReplicationSource source)

Method Summary

Modifier and Type	Method and Description
void	clear(String walGroupId) Remove all the elements from the queue corresponding to walGroupId
boolean	enqueueLog(org.apache.hadoop.fs.Path wal, String walGroupId) Enqueue the wal
MetricsSource	getMetrics()
int	getNumQueues() Returns number of queues.
(package private) long	getOldestWalAge()
private long	getOldestWalTimestamp()
PriorityBlockingQueue<org.apache.hadoop.fs.Path>	getQueue(String walGroupId) Return queue for the given walGroupId Please don't add or remove elements from the returned queue.
Map<String,PriorityBlockingQueue<org.apache.hadoop.fs.Path>>	getQueues()
int	getQueueSize(String walGroupId) Get the queue size for the given walGroupId.
void	remove(String walGroupId) Remove head from the queue corresponding to given walGroupId.

Methods inherited from class java.lang.Object

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

Field Detail

LOG

private static final org.slf4j.Logger LOG

queues

private Map<String,PriorityBlockingQueue<org.apache.hadoop.fs.Path>> queues

metrics

private MetricsSource metrics

conf

private org.apache.hadoop.conf.Configuration conf

queueSizePerGroup

private int queueSizePerGroup

logQueueWarnThreshold

private int logQueueWarnThreshold

source

private ReplicationSource source

Constructor Detail

ReplicationSourceLogQueue

public ReplicationSourceLogQueue(org.apache.hadoop.conf.Configuration conf,
                                 MetricsSource metrics,
                                 ReplicationSource source)

Method Detail

enqueueLog

public boolean enqueueLog(org.apache.hadoop.fs.Path wal,
                          String walGroupId)

Enqueue the wal

Parameters:

wal - wal to be enqueued

walGroupId - Key for the wal in @queues map

Returns:

boolean whether this is the first time we are seeing this walGroupId.

getQueueSize

public int getQueueSize(String walGroupId)

Get the queue size for the given walGroupId.

Parameters:

walGroupId - walGroupId

getNumQueues

public int getNumQueues()

Returns number of queues.

getQueues

public Map<String,PriorityBlockingQueue<org.apache.hadoop.fs.Path>> getQueues()

getQueue

public PriorityBlockingQueue<org.apache.hadoop.fs.Path> getQueue(String walGroupId)

Return queue for the given walGroupId Please don't add or remove elements from the returned queue. Use @enqueueLog and @remove methods respectively.

Parameters:

walGroupId - walGroupId

remove

public void remove(String walGroupId)

Remove head from the queue corresponding to given walGroupId.

Parameters:

walGroupId - walGroupId

clear

public void clear(String walGroupId)

Remove all the elements from the queue corresponding to walGroupId

Parameters:

walGroupId - walGroupId

getOldestWalAge

long getOldestWalAge()

getOldestWalTimestamp

private long getOldestWalTimestamp()

getMetrics

public MetricsSource getMetrics()