Package org.apache.hadoop.hbase.regionserver.regionreplication

Class RegionReplicationBufferManager

java.lang.Object

org.apache.hadoop.hbase.regionserver.regionreplication.RegionReplicationBufferManager

@Private
public class RegionReplicationBufferManager
extends Object

Manager the buffer size for all RegionReplicationSink.

If the buffer size exceeds the soft limit, we will find out the region with largest pending size and trigger a flush, so it can drop all the pending entries and save memories.

If the buffer size exceeds the hard limit, we will return false for increase(long) and let the RegionReplicationSink to drop the edits immediately.

Field Summary

Fields

Modifier and Type	Field	Description
private final ThreadPoolExecutor	executor
private static final org.slf4j.Logger	LOG
static final String	MAX_PENDING_SIZE	This is the total size of pending entries for all the sinks.
static final long	MAX_PENDING_SIZE_DEFAULT
private final long	maxPendingSize
private final AtomicLong	pendingSize
private final RegionServerServices	rsServices
static final String	SOFT_LIMIT_PERCENTAGE
static final float	SOFT_LIMIT_PERCENTAGE_DEFAULT
private final long	softMaxPendingSize

Constructor Summary

Constructors

Constructor	Description
RegionReplicationBufferManager(RegionServerServices rsServices)

Method Summary

Modifier and Type	Method	Description
void	decrease(long size)	Called after you ship the edits out.
private void	flush()
boolean	increase(long size)	Return whether we should just drop all the edits, if we have reached the hard limit of max pending size.
void	stop()

Methods inherited from class java.lang.Object

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

Field Details

LOG

private static final org.slf4j.Logger LOG

MAX_PENDING_SIZE

public static final String MAX_PENDING_SIZE

This is the total size of pending entries for all the sinks.

See Also:

• Constant Field Values

MAX_PENDING_SIZE_DEFAULT

public static final long MAX_PENDING_SIZE_DEFAULT

See Also:

• Constant Field Values

SOFT_LIMIT_PERCENTAGE

public static final String SOFT_LIMIT_PERCENTAGE

See Also:

• Constant Field Values

SOFT_LIMIT_PERCENTAGE_DEFAULT

public static final float SOFT_LIMIT_PERCENTAGE_DEFAULT

See Also:

• Constant Field Values

rsServices

private final RegionServerServices rsServices

maxPendingSize

private final long maxPendingSize

softMaxPendingSize

private final long softMaxPendingSize

pendingSize

private final AtomicLong pendingSize

executor

private final ThreadPoolExecutor executor

Constructor Details

RegionReplicationBufferManager

public RegionReplicationBufferManager(RegionServerServices rsServices)

Method Details

flush

private void flush()

increase

public boolean increase(long size)

Return whether we should just drop all the edits, if we have reached the hard limit of max pending size.

Returns:

true means OK, false means drop all the edits.

decrease

public void decrease(long size)

Called after you ship the edits out.

stop

public void stop()