Uses of Class
org.apache.hadoop.hbase.regionserver.HStore

Packages that use org.apache.hadoop.hbase.regionserver.HStore
  • Uses of org.apache.hadoop.hbase.regionserver.HStore in org.apache.hadoop.hbase.mob

    Methods in org.apache.hadoop.hbase.mob with parameters of type org.apache.hadoop.hbase.regionserver.HStore in in
    Modifier and Type
    Method
    Description
    protected void
    MobStoreEngine.createCompactor(org.apache.hadoop.conf.Configuration conf, org.apache.hadoop.hbase.regionserver.HStore store)
    Creates the DefaultMobCompactor.
    protected void
    MobStoreEngine.createStoreFlusher(org.apache.hadoop.conf.Configuration conf, org.apache.hadoop.hbase.regionserver.HStore store)
     
    Constructors in org.apache.hadoop.hbase.mob with parameters of type org.apache.hadoop.hbase.regionserver.HStore in in
    Modifier
    Constructor
    Description
     
    DefaultMobStoreCompactor(org.apache.hadoop.conf.Configuration conf, org.apache.hadoop.hbase.regionserver.HStore store)
     
     
    DefaultMobStoreFlusher(org.apache.hadoop.conf.Configuration conf, org.apache.hadoop.hbase.regionserver.HStore store)
     
  • Uses of org.apache.hadoop.hbase.regionserver.HStore in org.apache.hadoop.hbase.regionserver

    Subclasses of org.apache.hadoop.hbase.regionserver.HStore in in org.apache.hadoop.hbase.regionserver
    Modifier and Type
    Class
    Description
    class 
    org.apache.hadoop.hbase.regionserver.HMobStore
    The store implementation to save MOBs (medium objects), it extends the HStore.
    Fields in org.apache.hadoop.hbase.regionserver declared as org.apache.hadoop.hbase.regionserver.HStore in in
    Modifier and Type
    Field
    Description
    protected org.apache.hadoop.hbase.regionserver.HStore
    StoreFlusher.store
     
    protected org.apache.hadoop.hbase.regionserver.HStore
    StoreFlusher.store
     
    protected org.apache.hadoop.hbase.regionserver.HStore
    StoreFlusher.store
     
    protected final org.apache.hadoop.hbase.regionserver.HStore
    StoreScanner.store
     
    Fields in org.apache.hadoop.hbase.regionserver with type parameters of type org.apache.hadoop.hbase.regionserver.HStore in in
    Modifier and Type
    Field
    Description
    protected final Map<byte[],org.apache.hadoop.hbase.regionserver.HStore>
    HRegion.stores
     
    Methods in org.apache.hadoop.hbase.regionserver that return org.apache.hadoop.hbase.regionserver.HStore in in
    Modifier and Type
    Method
    Description
    org.apache.hadoop.hbase.regionserver.HStore
    CompactingMemStore.getStore()
     
    org.apache.hadoop.hbase.regionserver.HStore
    HRegion.getStore(byte[] column)
     
    protected org.apache.hadoop.hbase.regionserver.HStore
    HRegion.instantiateHStore(org.apache.hadoop.hbase.client.ColumnFamilyDescriptor family, boolean warmup)
     
    Methods in org.apache.hadoop.hbase.regionserver that return types with arguments of type org.apache.hadoop.hbase.regionserver.HStore in in
    Modifier and Type
    Method
    Description
    List<org.apache.hadoop.hbase.regionserver.HStore>
    HRegion.getStores()
     
    Collection<org.apache.hadoop.hbase.regionserver.HStore>
    FlushAllLargeStoresPolicy.selectStoresToFlush()
     
    Collection<org.apache.hadoop.hbase.regionserver.HStore>
    FlushAllStoresPolicy.selectStoresToFlush()
     
    Collection<org.apache.hadoop.hbase.regionserver.HStore>
    FlushNonSloppyStoresFirstPolicy.selectStoresToFlush()
    Returns the stores need to be flushed.
    abstract Collection<org.apache.hadoop.hbase.regionserver.HStore>
    FlushPolicy.selectStoresToFlush()
    Returns the stores need to be flushed.
    Methods in org.apache.hadoop.hbase.regionserver with parameters of type org.apache.hadoop.hbase.regionserver.HStore 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)
     
    static org.apache.hadoop.hbase.regionserver.StoreEngine<?,?,?,?>
    StoreEngine.create(org.apache.hadoop.hbase.regionserver.HStore store, org.apache.hadoop.conf.Configuration conf, CellComparator cellComparator)
    Create the StoreEngine configured for the given Store.
    protected void
    DefaultStoreEngine.createCompactionPolicy(org.apache.hadoop.conf.Configuration conf, org.apache.hadoop.hbase.regionserver.HStore store)
     
    protected void
    DefaultStoreEngine.createCompactor(org.apache.hadoop.conf.Configuration conf, org.apache.hadoop.hbase.regionserver.HStore store)
     
    protected void
    DateTieredStoreEngine.createComponents(org.apache.hadoop.conf.Configuration conf, org.apache.hadoop.hbase.regionserver.HStore store, CellComparator kvComparator)
     
    protected void
    DefaultStoreEngine.createComponents(org.apache.hadoop.conf.Configuration conf, org.apache.hadoop.hbase.regionserver.HStore store, CellComparator kvComparator)
     
    protected abstract void
    StoreEngine.createComponents(org.apache.hadoop.conf.Configuration conf, org.apache.hadoop.hbase.regionserver.HStore store, CellComparator cellComparator)
    Create the StoreEngine's components.
    protected void
    StripeStoreEngine.createComponents(org.apache.hadoop.conf.Configuration conf, org.apache.hadoop.hbase.regionserver.HStore store, CellComparator comparator)
     
    protected final void
    StoreEngine.createComponentsOnce(org.apache.hadoop.conf.Configuration conf, org.apache.hadoop.hbase.regionserver.HStore store, CellComparator cellComparator)
     
    protected org.apache.hadoop.hbase.regionserver.StoreEngine<?,?,?,?>
    HMobStore.createStoreEngine(org.apache.hadoop.hbase.regionserver.HStore store, org.apache.hadoop.conf.Configuration conf, CellComparator cellComparator)
    Creates the mob store engine.
    protected org.apache.hadoop.hbase.regionserver.StoreEngine<?,?,?,?>
    HStore.createStoreEngine(org.apache.hadoop.hbase.regionserver.HStore store, org.apache.hadoop.conf.Configuration conf, CellComparator kvComparator)
    Creates the store engine configured for the given Store.
    protected void
    DefaultStoreEngine.createStoreFlusher(org.apache.hadoop.conf.Configuration conf, org.apache.hadoop.hbase.regionserver.HStore store)
     
    boolean
    CompactSplit.isUnderCompaction(org.apache.hadoop.hbase.regionserver.HStore s)
    Check if this store is under compaction
    void
    RegionCoprocessorHost.postCompact(org.apache.hadoop.hbase.regionserver.HStore store, org.apache.hadoop.hbase.regionserver.HStoreFile resultFile, org.apache.hadoop.hbase.regionserver.compactions.CompactionLifeCycleTracker tracker, org.apache.hadoop.hbase.regionserver.compactions.CompactionRequest request, org.apache.hadoop.hbase.security.User user)
    Called after the store compaction has completed.
    void
    RegionCoprocessorHost.postCompactSelection(org.apache.hadoop.hbase.regionserver.HStore store, List<org.apache.hadoop.hbase.regionserver.HStoreFile> selected, org.apache.hadoop.hbase.regionserver.compactions.CompactionLifeCycleTracker tracker, org.apache.hadoop.hbase.regionserver.compactions.CompactionRequest request, org.apache.hadoop.hbase.security.User user)
    Called after the HStoreFiles to be compacted have been selected from the available candidates.
    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.postMemStoreCompaction(org.apache.hadoop.hbase.regionserver.HStore store)
    Invoked after in memory compaction.
    org.apache.hadoop.hbase.regionserver.InternalScanner
    RegionCoprocessorHost.preCompact(org.apache.hadoop.hbase.regionserver.HStore store, org.apache.hadoop.hbase.regionserver.InternalScanner scanner, org.apache.hadoop.hbase.regionserver.ScanType scanType, org.apache.hadoop.hbase.regionserver.compactions.CompactionLifeCycleTracker tracker, org.apache.hadoop.hbase.regionserver.compactions.CompactionRequest request, org.apache.hadoop.hbase.security.User user)
    Called prior to rewriting the store files selected for compaction
    org.apache.hadoop.hbase.regionserver.ScanInfo
    RegionCoprocessorHost.preCompactScannerOpen(org.apache.hadoop.hbase.regionserver.HStore store, org.apache.hadoop.hbase.regionserver.ScanType scanType, org.apache.hadoop.hbase.regionserver.compactions.CompactionLifeCycleTracker tracker, org.apache.hadoop.hbase.regionserver.compactions.CompactionRequest request, org.apache.hadoop.hbase.security.User user)
    Called prior to opening store scanner for compaction.
    boolean
    RegionCoprocessorHost.preCompactSelection(org.apache.hadoop.hbase.regionserver.HStore store, List<org.apache.hadoop.hbase.regionserver.HStoreFile> candidates, org.apache.hadoop.hbase.regionserver.compactions.CompactionLifeCycleTracker tracker, org.apache.hadoop.hbase.security.User user)
    Called prior to selecting the HStoreFiles for compaction from the list of currently available candidates.
    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.
    void
    RegionCoprocessorHost.preMemStoreCompaction(org.apache.hadoop.hbase.regionserver.HStore store)
    Invoked before in memory compaction.
    org.apache.hadoop.hbase.regionserver.InternalScanner
    RegionCoprocessorHost.preMemStoreCompactionCompact(org.apache.hadoop.hbase.regionserver.HStore store, org.apache.hadoop.hbase.regionserver.InternalScanner scanner)
    Invoked before compacting memstore.
    org.apache.hadoop.hbase.regionserver.ScanInfo
    RegionCoprocessorHost.preMemStoreCompactionCompactScannerOpen(org.apache.hadoop.hbase.regionserver.HStore store)
    Invoked before create StoreScanner for in memory compaction.
    org.apache.hadoop.hbase.regionserver.ScanInfo
    RegionCoprocessorHost.preStoreScannerOpen(org.apache.hadoop.hbase.regionserver.HStore store, org.apache.hadoop.hbase.client.Scan scan)
    Called before open store scanner for user scan.
    void
    CompactSplit.requestCompaction(org.apache.hadoop.hbase.regionserver.HRegion region, org.apache.hadoop.hbase.regionserver.HStore store, String why, int priority, org.apache.hadoop.hbase.regionserver.compactions.CompactionLifeCycleTracker tracker, org.apache.hadoop.hbase.security.User user)
     
    protected void
    CompactSplit.requestCompactionInternal(org.apache.hadoop.hbase.regionserver.HRegion region, org.apache.hadoop.hbase.regionserver.HStore store, String why, int priority, boolean selectNow, org.apache.hadoop.hbase.regionserver.compactions.CompactionLifeCycleTracker tracker, org.apache.hadoop.hbase.regionserver.CompactSplit.CompactionCompleteTracker completeTracker, org.apache.hadoop.hbase.security.User user)
     
    void
    CompactSplit.requestSystemCompaction(org.apache.hadoop.hbase.regionserver.HRegion region, org.apache.hadoop.hbase.regionserver.HStore store, String why)
     
    void
    CompactSplit.requestSystemCompaction(org.apache.hadoop.hbase.regionserver.HRegion region, org.apache.hadoop.hbase.regionserver.HStore store, String why, boolean giveUpIfRequestedOrCompacting)
     
    protected void
    HRegion.restoreEdit(org.apache.hadoop.hbase.regionserver.HStore s, org.apache.hadoop.hbase.Cell cell, org.apache.hadoop.hbase.regionserver.MemStoreSizing memstoreAccounting)
    Used by tests
    protected List<org.apache.hadoop.hbase.regionserver.KeyValueScanner>
    StoreScanner.selectScannersFrom(org.apache.hadoop.hbase.regionserver.HStore store, List<? extends org.apache.hadoop.hbase.regionserver.KeyValueScanner> allScanners)
    Filters the given list of scanners using Bloom filter, time range, and TTL.
    protected boolean
    FlushAllLargeStoresPolicy.shouldFlush(org.apache.hadoop.hbase.regionserver.HStore store)
     
    protected boolean
    FlushLargeStoresPolicy.shouldFlush(org.apache.hadoop.hbase.regionserver.HStore store)
     
    boolean
    KeyValueScanner.shouldUseScanner(org.apache.hadoop.hbase.client.Scan scan, org.apache.hadoop.hbase.regionserver.HStore store, long oldestUnexpiredTS)
    Allows to filter out scanners (both StoreFile and memstore) that we don't want to use based on criteria such as Bloom filters and timestamp ranges.
    boolean
    NonLazyKeyValueScanner.shouldUseScanner(org.apache.hadoop.hbase.client.Scan scan, org.apache.hadoop.hbase.regionserver.HStore store, long oldestUnexpiredTS)
     
    boolean
    SegmentScanner.shouldUseScanner(org.apache.hadoop.hbase.client.Scan scan, org.apache.hadoop.hbase.regionserver.HStore store, long oldestUnexpiredTS)
    This functionality should be resolved in the higher level which is MemStoreScanner, currently returns true as default.
    boolean
    StoreFileScanner.shouldUseScanner(org.apache.hadoop.hbase.client.Scan scan, org.apache.hadoop.hbase.regionserver.HStore store, long oldestUnexpiredTS)
     
    Method parameters in org.apache.hadoop.hbase.regionserver with type arguments of type org.apache.hadoop.hbase.regionserver.HStore in in
    Modifier and Type
    Method
    Description
    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)
     
    Constructors in org.apache.hadoop.hbase.regionserver with parameters of type org.apache.hadoop.hbase.regionserver.HStore in in
    Modifier
    Constructor
    Description
     
    CompactedHFilesDischargeHandler(org.apache.hadoop.hbase.Server server, org.apache.hadoop.hbase.executor.EventType eventType, org.apache.hadoop.hbase.regionserver.HStore store)
     
     
    CompactingMemStore(org.apache.hadoop.conf.Configuration conf, CellComparator c, org.apache.hadoop.hbase.regionserver.HStore store, org.apache.hadoop.hbase.regionserver.RegionServicesForStores regionServices, org.apache.hadoop.hbase.MemoryCompactionPolicy compactionPolicy)
     
     
    DefaultStoreFlusher(org.apache.hadoop.conf.Configuration conf, org.apache.hadoop.hbase.regionserver.HStore store)
     
     
    MemStoreCompactorSegmentsIterator(List<org.apache.hadoop.hbase.regionserver.ImmutableSegment> segments, CellComparator comparator, int compactionKVMax, org.apache.hadoop.hbase.regionserver.HStore store)
     
     
    MobStoreScanner(org.apache.hadoop.hbase.regionserver.HStore store, org.apache.hadoop.hbase.regionserver.ScanInfo scanInfo, org.apache.hadoop.hbase.client.Scan scan, NavigableSet<byte[]> columns, long readPt)
     
     
    ReversedStoreScanner(org.apache.hadoop.hbase.regionserver.HStore store, org.apache.hadoop.hbase.regionserver.ScanInfo scanInfo, org.apache.hadoop.hbase.client.Scan scan, NavigableSet<byte[]> columns, long readPt)
    Opens a scanner across memstore, snapshot, and all StoreFiles.
     
    StoreScanner(org.apache.hadoop.hbase.regionserver.HStore store, org.apache.hadoop.hbase.regionserver.ScanInfo scanInfo, List<? extends org.apache.hadoop.hbase.regionserver.KeyValueScanner> scanners, long smallestReadPoint, long earliestPutTs, byte[] dropDeletesFromRow, byte[] dropDeletesToRow)
    Used for compactions that drop deletes from a limited range of rows.
     
    StoreScanner(org.apache.hadoop.hbase.regionserver.HStore store, org.apache.hadoop.hbase.regionserver.ScanInfo scanInfo, List<? extends org.apache.hadoop.hbase.regionserver.KeyValueScanner> scanners, org.apache.hadoop.hbase.regionserver.ScanType scanType, long smallestReadPoint, long earliestPutTs)
    Used for store file compaction and memstore compaction.
     
    StoreScanner(org.apache.hadoop.hbase.regionserver.HStore store, org.apache.hadoop.hbase.regionserver.ScanInfo scanInfo, org.apache.hadoop.hbase.client.Scan scan, NavigableSet<byte[]> columns, long readPt)
    Opens a scanner across memstore, snapshot, and all StoreFiles.
     
    StripeStoreFlusher(org.apache.hadoop.conf.Configuration conf, org.apache.hadoop.hbase.regionserver.HStore store, org.apache.hadoop.hbase.regionserver.compactions.StripeCompactionPolicy policy, org.apache.hadoop.hbase.regionserver.StripeStoreFileManager stripes)
     
  • Uses of org.apache.hadoop.hbase.regionserver.HStore in org.apache.hadoop.hbase.regionserver.throttle

    Methods in org.apache.hadoop.hbase.regionserver.throttle with parameters of type org.apache.hadoop.hbase.regionserver.HStore in in
    Modifier and Type
    Method
    Description
    static String
    ThroughputControlUtil.getNameForThrottling(org.apache.hadoop.hbase.regionserver.HStore store, String opName)
    Generate a name for throttling, to prevent name conflict when multiple IO operation running parallel on the same store.