Uses of Interface
org.apache.hadoop.hbase.regionserver.throttle.ThroughputController

Packages that use org.apache.hadoop.hbase.regionserver.throttle.ThroughputController
Package
Description
org.apache.hadoop.hbase
 
org.apache.hadoop.hbase.mob
 
org.apache.hadoop.hbase.regionserver
 
org.apache.hadoop.hbase.regionserver.throttle
 

  • Uses of org.apache.hadoop.hbase.regionserver.throttle.ThroughputController in org.apache.hadoop.hbase

    Methods in org.apache.hadoop.hbase that return org.apache.hadoop.hbase.regionserver.throttle.ThroughputController in in
    Modifier and Type
    Method
    Description
    org.apache.hadoop.hbase.regionserver.throttle.ThroughputController
    MockRegionServerServices.getFlushThroughputController()
     

  • Uses of org.apache.hadoop.hbase.regionserver.throttle.ThroughputController in org.apache.hadoop.hbase.mob

    Methods in org.apache.hadoop.hbase.mob with parameters of type org.apache.hadoop.hbase.regionserver.throttle.ThroughputController in in
    Modifier and Type
    Method
    Description
    List<org.apache.hadoop.fs.Path>
    DefaultMobStoreCompactor.compact(org.apache.hadoop.hbase.regionserver.compactions.CompactionRequestImpl request, org.apache.hadoop.hbase.regionserver.throttle.ThroughputController throughputController, org.apache.hadoop.hbase.security.User user)
     
    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.
    protected boolean
    DefaultMobStoreCompactor.performCompaction(org.apache.hadoop.hbase.regionserver.compactions.Compactor.FileDetails fd, org.apache.hadoop.hbase.regionserver.InternalScanner scanner, org.apache.hadoop.hbase.regionserver.CellSink writer, long smallestReadPoint, boolean cleanSeqId, org.apache.hadoop.hbase.regionserver.throttle.ThroughputController throughputController, org.apache.hadoop.hbase.regionserver.compactions.CompactionRequestImpl request, org.apache.hadoop.hbase.regionserver.compactions.CompactionProgress progress)
    Performs compaction on a column family with the mob flag enabled.
    protected void
    DefaultMobStoreFlusher.performMobFlush(org.apache.hadoop.hbase.regionserver.MemStoreSnapshot snapshot, long cacheFlushId, org.apache.hadoop.hbase.regionserver.InternalScanner scanner, org.apache.hadoop.hbase.regionserver.StoreFileWriter writer, org.apache.hadoop.hbase.monitoring.MonitoredTask status, org.apache.hadoop.hbase.regionserver.throttle.ThroughputController throughputController, Consumer<org.apache.hadoop.fs.Path> writerCreationTracker)
    Flushes the cells in the mob store.

  • Uses of org.apache.hadoop.hbase.regionserver.throttle.ThroughputController in org.apache.hadoop.hbase.regionserver

    Methods in org.apache.hadoop.hbase.regionserver that return org.apache.hadoop.hbase.regionserver.throttle.ThroughputController in in
    Modifier and Type
    Method
    Description
    org.apache.hadoop.hbase.regionserver.throttle.ThroughputController
    CompactSplit.getCompactionThroughputController()
     
    org.apache.hadoop.hbase.regionserver.throttle.ThroughputController
    HRegionServer.getFlushThroughputController()
     
    org.apache.hadoop.hbase.regionserver.throttle.ThroughputController
    RegionServerServices.getFlushThroughputController()
    Returns the controller to avoid flush too fast
    Methods in org.apache.hadoop.hbase.regionserver with parameters of type org.apache.hadoop.hbase.regionserver.throttle.ThroughputController in in
    Modifier and Type
    Method
    Description
    boolean
    HRegion.compact(org.apache.hadoop.hbase.regionserver.compactions.CompactionContext compaction, org.apache.hadoop.hbase.regionserver.HStore store, org.apache.hadoop.hbase.regionserver.throttle.ThroughputController throughputController)
    Called by compaction thread and after region is opened to compact the HStores if necessary.
    boolean
    HRegion.compact(org.apache.hadoop.hbase.regionserver.compactions.CompactionContext compaction, org.apache.hadoop.hbase.regionserver.HStore store, org.apache.hadoop.hbase.regionserver.throttle.ThroughputController throughputController, org.apache.hadoop.hbase.security.User user)
    We are trying to remove / relax the region read lock for compaction.
    List<org.apache.hadoop.hbase.regionserver.HStoreFile>
    HStore.compact(org.apache.hadoop.hbase.regionserver.compactions.CompactionContext compaction, org.apache.hadoop.hbase.regionserver.throttle.ThroughputController throughputController, org.apache.hadoop.hbase.security.User user)
    Compact the StoreFiles.
    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)
     

  • Uses of org.apache.hadoop.hbase.regionserver.throttle.ThroughputController in org.apache.hadoop.hbase.regionserver.throttle

    Classes in org.apache.hadoop.hbase.regionserver.throttle that implement org.apache.hadoop.hbase.regionserver.throttle.ThroughputController in in
    Modifier and Type
    Class
    Description
    class 
    org.apache.hadoop.hbase.regionserver.throttle.NoLimitThroughputController
     
    class 
    org.apache.hadoop.hbase.regionserver.throttle.PressureAwareCompactionThroughputController
    A throughput controller which uses the follow schema to limit throughput If compaction pressure is greater than 1.0, no limitation. In off peak hours, use a fixed throughput limitation "hbase.hstore.compaction.throughput.offpeak" In normal hours, the max throughput is tuned between "hbase.hstore.compaction.throughput.lower.bound" and "hbase.hstore.compaction.throughput.higher.bound", using the formula "lower + (higer - lower) * compactionPressure", where compactionPressure is in range [0.0, 1.0]
    class 
    org.apache.hadoop.hbase.regionserver.throttle.PressureAwareFlushThroughputController
    A throughput controller which uses the follow schema to limit throughput If flush pressure is greater than or equal to 1.0, no limitation. In normal case, the max throughput is tuned between "hbase.hstore.flush.throughput.lower.bound" and "hbase.hstore.flush.throughput.upper.bound", using the formula "lower + (upper - lower) * flushPressure", where flushPressure is in range [0.0, 1.0)
    class 
    org.apache.hadoop.hbase.regionserver.throttle.PressureAwareThroughputController
     
    Methods in org.apache.hadoop.hbase.regionserver.throttle that return org.apache.hadoop.hbase.regionserver.throttle.ThroughputController in in
    Modifier and Type
    Method
    Description
    static org.apache.hadoop.hbase.regionserver.throttle.ThroughputController
    CompactionThroughputControllerFactory.create(org.apache.hadoop.hbase.regionserver.RegionServerServices server, org.apache.hadoop.conf.Configuration conf)
     
    static org.apache.hadoop.hbase.regionserver.throttle.ThroughputController
    FlushThroughputControllerFactory.create(org.apache.hadoop.hbase.regionserver.RegionServerServices server, org.apache.hadoop.conf.Configuration conf)
     
    Methods in org.apache.hadoop.hbase.regionserver.throttle that return types with arguments of type org.apache.hadoop.hbase.regionserver.throttle.ThroughputController in in
    Modifier and Type
    Method
    Description
    static Class<? extends org.apache.hadoop.hbase.regionserver.throttle.ThroughputController>
    CompactionThroughputControllerFactory.getThroughputControllerClass(org.apache.hadoop.conf.Configuration conf)
     
    static Class<? extends org.apache.hadoop.hbase.regionserver.throttle.ThroughputController>
    FlushThroughputControllerFactory.getThroughputControllerClass(org.apache.hadoop.conf.Configuration conf)