org.apache.hadoop.hbase.regionserver

Class TestHeapMemoryManager.MemstoreFlusherStub

java.lang.Object

org.apache.hadoop.hbase.regionserver.TestHeapMemoryManager.MemstoreFlusherStub

All Implemented Interfaces:

org.apache.hadoop.hbase.regionserver.FlushRequester

Enclosing class:

TestHeapMemoryManager

private static class TestHeapMemoryManager.MemstoreFlusherStub
extends Object
implements org.apache.hadoop.hbase.regionserver.FlushRequester

Field Summary

Fields

Modifier and Type	Field and Description
(package private) org.apache.hadoop.hbase.regionserver.FlushType	flushType
(package private) org.apache.hadoop.hbase.regionserver.FlushRequestListener	listener
(package private) long	memstoreSize

Constructor Summary

Constructors

Constructor and Description
MemstoreFlusherStub(long memstoreSize)

Method Summary

Modifier and Type	Method and Description
void	registerFlushRequestListener(org.apache.hadoop.hbase.regionserver.FlushRequestListener listener)
boolean	requestDelayedFlush(org.apache.hadoop.hbase.regionserver.HRegion region, long delay)
boolean	requestFlush(org.apache.hadoop.hbase.regionserver.HRegion region, org.apache.hadoop.hbase.regionserver.FlushLifeCycleTracker tracker)
boolean	requestFlush(org.apache.hadoop.hbase.regionserver.HRegion region, List<byte[]> families, org.apache.hadoop.hbase.regionserver.FlushLifeCycleTracker tracker)
void	setGlobalMemStoreLimit(long globalMemStoreSize)
boolean	unregisterFlushRequestListener(org.apache.hadoop.hbase.regionserver.FlushRequestListener listener)

Methods inherited from class java.lang.Object

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

Field Detail

memstoreSize

long memstoreSize

listener

org.apache.hadoop.hbase.regionserver.FlushRequestListener listener

flushType

org.apache.hadoop.hbase.regionserver.FlushType flushType

Constructor Detail

MemstoreFlusherStub

public MemstoreFlusherStub(long memstoreSize)

Method Detail

requestFlush

public boolean requestFlush(org.apache.hadoop.hbase.regionserver.HRegion region,
                            org.apache.hadoop.hbase.regionserver.FlushLifeCycleTracker tracker)

Specified by:

requestFlush in interface org.apache.hadoop.hbase.regionserver.FlushRequester

requestFlush

public boolean requestFlush(org.apache.hadoop.hbase.regionserver.HRegion region,
                            List<byte[]> families,
                            org.apache.hadoop.hbase.regionserver.FlushLifeCycleTracker tracker)

Specified by:

requestFlush in interface org.apache.hadoop.hbase.regionserver.FlushRequester

requestDelayedFlush

public boolean requestDelayedFlush(org.apache.hadoop.hbase.regionserver.HRegion region,
                                   long delay)

Specified by:

requestDelayedFlush in interface org.apache.hadoop.hbase.regionserver.FlushRequester

registerFlushRequestListener

public void registerFlushRequestListener(org.apache.hadoop.hbase.regionserver.FlushRequestListener listener)

Specified by:

registerFlushRequestListener in interface org.apache.hadoop.hbase.regionserver.FlushRequester

unregisterFlushRequestListener

public boolean unregisterFlushRequestListener(org.apache.hadoop.hbase.regionserver.FlushRequestListener listener)

Specified by:

unregisterFlushRequestListener in interface org.apache.hadoop.hbase.regionserver.FlushRequester

setGlobalMemStoreLimit

public void setGlobalMemStoreLimit(long globalMemStoreSize)

Specified by:

setGlobalMemStoreLimit in interface org.apache.hadoop.hbase.regionserver.FlushRequester