Uses of Interface
org.apache.hadoop.hbase.regionserver.FlushLifeCycleTracker

Packages that use org.apache.hadoop.hbase.regionserver.FlushLifeCycleTracker
  • Uses of org.apache.hadoop.hbase.regionserver.FlushLifeCycleTracker in org.apache.hadoop.hbase.coprocessor

    Methods in org.apache.hadoop.hbase.coprocessor with parameters of type org.apache.hadoop.hbase.regionserver.FlushLifeCycleTracker in in
    Modifier and Type
    Method
    Description
    default void
    RegionObserver.postFlush(org.apache.hadoop.hbase.coprocessor.ObserverContext<org.apache.hadoop.hbase.coprocessor.RegionCoprocessorEnvironment> c, org.apache.hadoop.hbase.regionserver.FlushLifeCycleTracker tracker)
    Called after the memstore is flushed to disk.
    default void
    RegionObserver.postFlush(org.apache.hadoop.hbase.coprocessor.ObserverContext<org.apache.hadoop.hbase.coprocessor.RegionCoprocessorEnvironment> c, org.apache.hadoop.hbase.regionserver.Store store, org.apache.hadoop.hbase.regionserver.StoreFile resultFile, org.apache.hadoop.hbase.regionserver.FlushLifeCycleTracker tracker)
    Called after a Store's memstore is flushed to disk.
    default void
    RegionObserver.preFlush(org.apache.hadoop.hbase.coprocessor.ObserverContext<org.apache.hadoop.hbase.coprocessor.RegionCoprocessorEnvironment> c, org.apache.hadoop.hbase.regionserver.FlushLifeCycleTracker tracker)
    Called before the memstore is flushed to disk.
    default org.apache.hadoop.hbase.regionserver.InternalScanner
    RegionObserver.preFlush(org.apache.hadoop.hbase.coprocessor.ObserverContext<org.apache.hadoop.hbase.coprocessor.RegionCoprocessorEnvironment> c, org.apache.hadoop.hbase.regionserver.Store store, org.apache.hadoop.hbase.regionserver.InternalScanner scanner, org.apache.hadoop.hbase.regionserver.FlushLifeCycleTracker tracker)
    Called before a Store's memstore is flushed to disk.
    default void
    RegionObserver.preFlushScannerOpen(org.apache.hadoop.hbase.coprocessor.ObserverContext<org.apache.hadoop.hbase.coprocessor.RegionCoprocessorEnvironment> c, org.apache.hadoop.hbase.regionserver.Store store, org.apache.hadoop.hbase.regionserver.ScanOptions options, org.apache.hadoop.hbase.regionserver.FlushLifeCycleTracker tracker)
    Called before we open store scanner for flush.
  • Uses of org.apache.hadoop.hbase.regionserver.FlushLifeCycleTracker in org.apache.hadoop.hbase.mob

    Methods in org.apache.hadoop.hbase.mob with parameters of type org.apache.hadoop.hbase.regionserver.FlushLifeCycleTracker in in
    Modifier and Type
    Method
    Description
    List<org.apache.hadoop.fs.Path>
    DefaultMobStoreFlusher.flushSnapshot(org.apache.hadoop.hbase.regionserver.MemStoreSnapshot snapshot, long cacheFlushId, org.apache.hadoop.hbase.monitoring.MonitoredTask status, org.apache.hadoop.hbase.regionserver.throttle.ThroughputController throughputController, org.apache.hadoop.hbase.regionserver.FlushLifeCycleTracker tracker, Consumer<org.apache.hadoop.fs.Path> writerCreationTracker)
    Flushes the snapshot of the MemStore.
  • Uses of org.apache.hadoop.hbase.regionserver.FlushLifeCycleTracker in org.apache.hadoop.hbase.regionserver

    Fields in org.apache.hadoop.hbase.regionserver declared as org.apache.hadoop.hbase.regionserver.FlushLifeCycleTracker in in
    Modifier and Type
    Field
    Description
    static final org.apache.hadoop.hbase.regionserver.FlushLifeCycleTracker
    FlushLifeCycleTracker.DUMMY
     
    Methods in org.apache.hadoop.hbase.regionserver with parameters of type org.apache.hadoop.hbase.regionserver.FlushLifeCycleTracker in in
    Modifier and Type
    Method
    Description
    org.apache.hadoop.hbase.regionserver.StoreFlushContext
    HStore.createFlushContext(long cacheFlushId, org.apache.hadoop.hbase.regionserver.FlushLifeCycleTracker tracker)
     
    org.apache.hadoop.hbase.regionserver.HRegion.FlushResultImpl
    HRegion.flushcache(List<byte[]> families, boolean writeFlushRequestWalMarker, org.apache.hadoop.hbase.regionserver.FlushLifeCycleTracker tracker)
    Flush the cache.
    protected List<org.apache.hadoop.fs.Path>
    HStore.flushCache(long logCacheFlushId, org.apache.hadoop.hbase.regionserver.MemStoreSnapshot snapshot, org.apache.hadoop.hbase.monitoring.MonitoredTask status, org.apache.hadoop.hbase.regionserver.throttle.ThroughputController throughputController, org.apache.hadoop.hbase.regionserver.FlushLifeCycleTracker tracker, Consumer<org.apache.hadoop.fs.Path> writerCreationTracker)
    Write out current snapshot.
    List<org.apache.hadoop.fs.Path>
    DefaultStoreFlusher.flushSnapshot(org.apache.hadoop.hbase.regionserver.MemStoreSnapshot snapshot, long cacheFlushId, org.apache.hadoop.hbase.monitoring.MonitoredTask status, org.apache.hadoop.hbase.regionserver.throttle.ThroughputController throughputController, org.apache.hadoop.hbase.regionserver.FlushLifeCycleTracker tracker, Consumer<org.apache.hadoop.fs.Path> writerCreationTracker)
     
    List<org.apache.hadoop.fs.Path>
    StripeStoreFlusher.flushSnapshot(org.apache.hadoop.hbase.regionserver.MemStoreSnapshot snapshot, long cacheFlushSeqNum, org.apache.hadoop.hbase.monitoring.MonitoredTask status, org.apache.hadoop.hbase.regionserver.throttle.ThroughputController throughputController, org.apache.hadoop.hbase.regionserver.FlushLifeCycleTracker tracker, Consumer<org.apache.hadoop.fs.Path> writerCreationTracker)
     
    protected org.apache.hadoop.hbase.regionserver.HRegion.FlushResultImpl
    HRegion.internalFlushcache(org.apache.hadoop.hbase.wal.WAL wal, long myseqid, Collection<org.apache.hadoop.hbase.regionserver.HStore> storesToFlush, org.apache.hadoop.hbase.monitoring.MonitoredTask status, boolean writeFlushWalMarker, org.apache.hadoop.hbase.regionserver.FlushLifeCycleTracker tracker)
    Flush the memstore.
    protected org.apache.hadoop.hbase.regionserver.HRegion.PrepareFlushResult
    HRegion.internalPrepareFlushCache(org.apache.hadoop.hbase.wal.WAL wal, long myseqid, Collection<org.apache.hadoop.hbase.regionserver.HStore> storesToFlush, org.apache.hadoop.hbase.monitoring.MonitoredTask status, boolean writeFlushWalMarker, org.apache.hadoop.hbase.regionserver.FlushLifeCycleTracker tracker)
     
    void
    RegionCoprocessorHost.postFlush(org.apache.hadoop.hbase.regionserver.FlushLifeCycleTracker tracker)
    Invoked after a memstore flush
    void
    RegionCoprocessorHost.postFlush(org.apache.hadoop.hbase.regionserver.HStore store, org.apache.hadoop.hbase.regionserver.HStoreFile storeFile, org.apache.hadoop.hbase.regionserver.FlushLifeCycleTracker tracker)
    Invoked after a memstore flush
    void
    RegionCoprocessorHost.preFlush(org.apache.hadoop.hbase.regionserver.FlushLifeCycleTracker tracker)
    Invoked before a memstore flush
    org.apache.hadoop.hbase.regionserver.InternalScanner
    RegionCoprocessorHost.preFlush(org.apache.hadoop.hbase.regionserver.HStore store, org.apache.hadoop.hbase.regionserver.InternalScanner scanner, org.apache.hadoop.hbase.regionserver.FlushLifeCycleTracker tracker)
    Invoked before a memstore flush
    org.apache.hadoop.hbase.regionserver.ScanInfo
    RegionCoprocessorHost.preFlushScannerOpen(org.apache.hadoop.hbase.regionserver.HStore store, org.apache.hadoop.hbase.regionserver.FlushLifeCycleTracker tracker)
    Invoked before create StoreScanner for flush.
    boolean
    FlushRequester.requestFlush(org.apache.hadoop.hbase.regionserver.HRegion region, List<byte[]> families, org.apache.hadoop.hbase.regionserver.FlushLifeCycleTracker tracker)
    Tell the listener the cache needs to be flushed.
    boolean
    FlushRequester.requestFlush(org.apache.hadoop.hbase.regionserver.HRegion region, org.apache.hadoop.hbase.regionserver.FlushLifeCycleTracker tracker)
    Tell the listener the cache needs to be flushed.
    void
    HRegion.requestFlush(org.apache.hadoop.hbase.regionserver.FlushLifeCycleTracker tracker)
     
    boolean
    MemStoreFlusher.requestFlush(org.apache.hadoop.hbase.regionserver.HRegion r, List<byte[]> families, org.apache.hadoop.hbase.regionserver.FlushLifeCycleTracker tracker)
     
    boolean
    MemStoreFlusher.requestFlush(org.apache.hadoop.hbase.regionserver.HRegion r, org.apache.hadoop.hbase.regionserver.FlushLifeCycleTracker tracker)
     
    void
    Region.requestFlush(org.apache.hadoop.hbase.regionserver.FlushLifeCycleTracker tracker)
    Request flush on this region.