Interface FlushRequester

All Known Implementing Classes:
MemStoreFlusher

@Private public interface FlushRequester
Request a flush.
  • Method Details

    • 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

      Register a FlushRequestListener
    • unregisterFlushRequestListener

      Unregister the given FlushRequestListener
      Returns:
      true when passed listener is unregistered successfully.
    • setGlobalMemStoreLimit

      void setGlobalMemStoreLimit(long globalMemStoreSize)
      Sets the global memstore limit to a new size.