@InterfaceAudience.Private
public interface FlushRequester
Modifier and Type | Method and Description |
---|---|
void |
registerFlushRequestListener(FlushRequestListener listener)
Register a FlushRequestListener
|
boolean |
requestDelayedFlush(HRegion region,
long delay,
boolean forceFlushAllStores)
Tell the listener the cache needs to be flushed after a delay
|
boolean |
requestFlush(HRegion region,
boolean forceFlushAllStores,
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
|
boolean requestFlush(HRegion region, boolean forceFlushAllStores, FlushLifeCycleTracker tracker)
region
- the Region requesting the cache flushforceFlushAllStores
- whether we want to flush all stores. e.g., when request from log
rolling.boolean requestDelayedFlush(HRegion region, long delay, boolean forceFlushAllStores)
region
- the Region requesting the cache flushdelay
- after how much time should the flush happenforceFlushAllStores
- whether we want to flush all stores. e.g., when request from log
rolling.void registerFlushRequestListener(FlushRequestListener listener)
listener
- boolean unregisterFlushRequestListener(FlushRequestListener listener)
listener
- void setGlobalMemStoreLimit(long globalMemStoreSize)
globalMemStoreSize
- Copyright © 2007–2019 Cloudera. All rights reserved.