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)
void	requestDelayedFlush(org.apache.hadoop.hbase.regionserver.HRegion region, long delay, boolean forceFlushAllStores)
void	requestFlush(org.apache.hadoop.hbase.regionserver.HRegion region, boolean forceFlushAllStores, 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 void requestFlush(org.apache.hadoop.hbase.regionserver.HRegion region,
                         boolean forceFlushAllStores,
                         org.apache.hadoop.hbase.regionserver.FlushLifeCycleTracker tracker)

Specified by:

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

requestDelayedFlush

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

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