org.apache.hadoop.hbase.regionserver

Interface FlushRequester

All Known Implementing Classes:

MemStoreFlusher

@InterfaceAudience.Private
public interface FlushRequester

Request a flush.

Method Summary

Modifier and Type	Method and Description
void	registerFlushRequestListener(FlushRequestListener listener) Register a FlushRequestListener
boolean	requestDelayedFlush(HRegion region, long delay) Tell the listener the cache needs to be flushed after a delay
boolean	requestFlush(HRegion region, FlushLifeCycleTracker tracker) Tell the listener the cache needs to be flushed.
boolean	requestFlush(HRegion region, List<byte[]> families, FlushLifeCycleTracker tracker) Tell the listener the cache needs to be flushed.
void	setGlobalMemStoreLimit(long globalMemStoreSize) Sets the global memstore limit to a new size.
boolean	unregisterFlushRequestListener(FlushRequestListener listener) Unregister the given FlushRequestListener

Method Detail

requestFlush

boolean requestFlush(HRegion region,
                     FlushLifeCycleTracker tracker)

Tell the listener the cache needs to be flushed.

Parameters:

region - the Region requesting the cache flush

Returns:

true if our region is added into the queue, false otherwise

requestFlush

boolean requestFlush(HRegion region,
                     List<byte[]> families,
                     FlushLifeCycleTracker tracker)

Tell the listener the cache needs to be flushed.

Parameters:

region - the Region requesting the cache flush

families - stores of region to flush, if null then use flush policy

Returns:

true if our region is added into the queue, false otherwise

requestDelayedFlush

boolean requestDelayedFlush(HRegion region,
                            long delay)

Tell the listener the cache needs to be flushed after a delay

Parameters:

region - the Region requesting the cache flush

delay - after how much time should the flush happen

Returns:

true if our region is added into the queue, false otherwise

registerFlushRequestListener

void registerFlushRequestListener(FlushRequestListener listener)

Register a FlushRequestListener

Parameters:

listener -

unregisterFlushRequestListener

boolean unregisterFlushRequestListener(FlushRequestListener listener)

Unregister the given FlushRequestListener

Parameters:

listener -

Returns:

true when passed listener is unregistered successfully.

setGlobalMemStoreLimit

void setGlobalMemStoreLimit(long globalMemStoreSize)

Sets the global memstore limit to a new size.

Parameters:

globalMemStoreSize -