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

Packages that use HStore

Package	Description
org.apache.hadoop.hbase.mob
org.apache.hadoop.hbase.regionserver
org.apache.hadoop.hbase.regionserver.compactions
org.apache.hadoop.hbase.regionserver.throttle

Uses of HStore in org.apache.hadoop.hbase.mob

Methods in org.apache.hadoop.hbase.mob with parameters of type HStore

Modifier and Type	Method and Description
protected void	MobStoreEngine.createCompactor(org.apache.hadoop.conf.Configuration conf, HStore store) Creates the DefaultMobCompactor.
protected void	MobStoreEngine.createStoreFlusher(org.apache.hadoop.conf.Configuration conf, HStore store)

Constructors in org.apache.hadoop.hbase.mob with parameters of type HStore

Constructor and Description
DefaultMobStoreCompactor(org.apache.hadoop.conf.Configuration conf, HStore store)
DefaultMobStoreFlusher(org.apache.hadoop.conf.Configuration conf, HStore store)

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

Subclasses of HStore in org.apache.hadoop.hbase.regionserver

Modifier and Type	Class and Description
class	HMobStore The store implementation to save MOBs (medium objects), it extends the HStore.

Fields in org.apache.hadoop.hbase.regionserver declared as HStore

Modifier and Type	Field and Description
private HStore	CompactingMemStore.store
private HStore	CompactedHFilesDischargeHandler.store
private HStore	CompactSplit.CompactionRunner.store
protected HStore	StoreScanner.store
protected HStore	StoreFlusher.store

Fields in org.apache.hadoop.hbase.regionserver with type parameters of type HStore

Modifier and Type	Field and Description
private ConcurrentMap<HStore,Long>	HRegion.lastStoreFlushTimeMap
private Collection<HStore>	FlushNonSloppyStoresFirstPolicy.regularStores
private Collection<HStore>	FlushNonSloppyStoresFirstPolicy.sloppyStores
protected Map<byte[],HStore>	HRegion.stores

Methods in org.apache.hadoop.hbase.regionserver that return HStore

Modifier and Type	Method and Description
HStore	CompactingMemStore.getStore()
HStore	HRegion.getStore(byte[] column)
private HStore	HRegion.getStore(Cell cell) Return HStore instance.
private static HStore	CompactionTool.CompactionWorker.getStore(org.apache.hadoop.conf.Configuration conf, org.apache.hadoop.fs.FileSystem fs, org.apache.hadoop.fs.Path tableDir, TableDescriptor htd, RegionInfo hri, String familyName)
protected HStore	HRegion.instantiateHStore(ColumnFamilyDescriptor family, boolean warmup)

Methods in org.apache.hadoop.hbase.regionserver that return types with arguments of type HStore

Modifier and Type	Method and Description
private Collection<HStore>	HRegion.getSpecificStores(List<byte[]> families) get stores which matches the specified families
List<HStore>	HRegion.getStores()
Collection<HStore>	FlushAllStoresPolicy.selectStoresToFlush()
abstract Collection<HStore>	FlushPolicy.selectStoresToFlush()
Collection<HStore>	FlushAllLargeStoresPolicy.selectStoresToFlush()
Collection<HStore>	FlushNonSloppyStoresFirstPolicy.selectStoresToFlush()

Methods in org.apache.hadoop.hbase.regionserver with parameters of type HStore

Modifier and Type	Method and Description
private void	HRegion.applyToMemStore(HStore store, Cell cell, MemStoreSizing memstoreAccounting)
private void	HRegion.applyToMemStore(HStore store, List<Cell> cells, boolean delta, MemStoreSizing memstoreAccounting)
boolean	HRegion.compact(CompactionContext compaction, HStore store, ThroughputController throughputController) Called by compaction thread and after region is opened to compact the HStores if necessary.
boolean	HRegion.compact(CompactionContext compaction, HStore store, ThroughputController throughputController, User user)
static StoreEngine<?,?,?,?>	StoreEngine.create(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, HStore store)
protected void	DefaultStoreEngine.createCompactor(org.apache.hadoop.conf.Configuration conf, HStore store)
protected void	StripeStoreEngine.createComponents(org.apache.hadoop.conf.Configuration conf, HStore store, CellComparator comparator)
protected void	DefaultStoreEngine.createComponents(org.apache.hadoop.conf.Configuration conf, HStore store, CellComparator kvComparator)
protected abstract void	StoreEngine.createComponents(org.apache.hadoop.conf.Configuration conf, HStore store, CellComparator cellComparator) Create the StoreEngine's components.
protected void	DateTieredStoreEngine.createComponents(org.apache.hadoop.conf.Configuration conf, HStore store, CellComparator kvComparator)
private void	StoreEngine.createComponentsOnce(org.apache.hadoop.conf.Configuration conf, HStore store, CellComparator cellComparator)
private InternalScanner	MemStoreCompactorSegmentsIterator.createScanner(HStore store, List<KeyValueScanner> scanners) Creates the scanner for compacting the pipeline.
protected StoreEngine<?,?,?,?>	HMobStore.createStoreEngine(HStore store, org.apache.hadoop.conf.Configuration conf, CellComparator cellComparator) Creates the mob store engine.
protected StoreEngine<?,?,?,?>	HStore.createStoreEngine(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, HStore store)
private MemStoreSize	HRegion.doDropStoreMemStoreContentsForSeqId(HStore s, long currentSeqId)
private MemStoreSize	HRegion.dropMemStoreContentsForSeqId(long seqId, HStore store) Drops the memstore contents after replaying a flush descriptor or region open event replay if the memstore edits have seqNums smaller than the given seq id
void	RegionCoprocessorHost.postCompact(HStore store, HStoreFile resultFile, CompactionLifeCycleTracker tracker, CompactionRequest request, User user) Called after the store compaction has completed.
void	RegionCoprocessorHost.postCompactSelection(HStore store, List<HStoreFile> selected, CompactionLifeCycleTracker tracker, CompactionRequest request, User user) Called after the HStoreFiles to be compacted have been selected from the available candidates.
void	RegionCoprocessorHost.postFlush(HStore store, HStoreFile storeFile, FlushLifeCycleTracker tracker) Invoked after a memstore flush
void	RegionCoprocessorHost.postMemStoreCompaction(HStore store) Invoked after in memory compaction.
InternalScanner	RegionCoprocessorHost.preCompact(HStore store, InternalScanner scanner, ScanType scanType, CompactionLifeCycleTracker tracker, CompactionRequest request, User user) Called prior to rewriting the store files selected for compaction
ScanInfo	RegionCoprocessorHost.preCompactScannerOpen(HStore store, ScanType scanType, CompactionLifeCycleTracker tracker, CompactionRequest request, User user) Called prior to opening store scanner for compaction.
boolean	RegionCoprocessorHost.preCompactSelection(HStore store, List<HStoreFile> candidates, CompactionLifeCycleTracker tracker, User user) Called prior to selecting the HStoreFiles for compaction from the list of currently available candidates.
InternalScanner	RegionCoprocessorHost.preFlush(HStore store, InternalScanner scanner, FlushLifeCycleTracker tracker) Invoked before a memstore flush
ScanInfo	RegionCoprocessorHost.preFlushScannerOpen(HStore store, FlushLifeCycleTracker tracker) Invoked before create StoreScanner for flush.
void	RegionCoprocessorHost.preMemStoreCompaction(HStore store) Invoked before in memory compaction.
InternalScanner	RegionCoprocessorHost.preMemStoreCompactionCompact(HStore store, InternalScanner scanner) Invoked before compacting memstore.
ScanInfo	RegionCoprocessorHost.preMemStoreCompactionCompactScannerOpen(HStore store) Invoked before create StoreScanner for in memory compaction.
ScanInfo	RegionCoprocessorHost.preStoreScannerOpen(HStore store, Scan scan) Called before open store scanner for user scan.
private List<Cell>	HRegion.MutationBatchOperation.reckonDeltasByStore(HStore store, Mutation mutation, long now, List<Cell> deltas, List<Cell> results) Reckon the Cells to apply to WAL, memstore, and to return to the Client in passed column family/Store.
void	CompactSplit.requestCompaction(HRegion region, HStore store, String why, int priority, CompactionLifeCycleTracker tracker, User user)
private void	CompactSplit.requestCompactionInternal(HRegion region, HStore store, String why, int priority, boolean selectNow, CompactionLifeCycleTracker tracker, CompactSplit.CompactionCompleteTracker completeTracker, User user)
void	CompactSplit.requestSystemCompaction(HRegion region, HStore store, String why)
protected void	HRegion.restoreEdit(HStore s, Cell cell, MemStoreSizing memstoreAccounting) Used by tests
private Optional<CompactionContext>	CompactSplit.selectCompaction(HRegion region, HStore store, int priority, CompactionLifeCycleTracker tracker, CompactSplit.CompactionCompleteTracker completeTracker, User user)
protected List<KeyValueScanner>	StoreScanner.selectScannersFrom(HStore store, List<? extends KeyValueScanner> allScanners) Filters the given list of scanners using Bloom filter, time range, and TTL.
protected boolean	FlushLargeStoresPolicy.shouldFlush(HStore store)
protected boolean	FlushAllLargeStoresPolicy.shouldFlush(HStore store)
(package private) boolean	HRegion.shouldFlushStore(HStore store) Should the store be flushed because it is old enough.
boolean	StoreFileScanner.shouldUseScanner(Scan scan, HStore store, long oldestUnexpiredTS)
boolean	NonLazyKeyValueScanner.shouldUseScanner(Scan scan, HStore store, long oldestUnexpiredTS)
boolean	KeyValueScanner.shouldUseScanner(Scan scan, 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	SegmentScanner.shouldUseScanner(Scan scan, HStore store, long oldestUnexpiredTS) This functionality should be resolved in the higher level which is MemStoreScanner, currently returns true as default.

Method parameters in org.apache.hadoop.hbase.regionserver with type arguments of type HStore

Modifier and Type	Method and Description
private HRegion.FlushResultImpl	HRegion.internalFlushcache(Collection<HStore> storesToFlush, MonitoredTask status, boolean writeFlushWalMarker, FlushLifeCycleTracker tracker) Flushing given stores.
protected HRegion.FlushResultImpl	HRegion.internalFlushcache(WAL wal, long myseqid, Collection<HStore> storesToFlush, MonitoredTask status, boolean writeFlushWalMarker, FlushLifeCycleTracker tracker) Flush the memstore.
protected HRegion.FlushResultImpl	HRegion.internalFlushCacheAndCommit(WAL wal, MonitoredTask status, HRegion.PrepareFlushResult prepareResult, Collection<HStore> storesToFlush)
protected HRegion.PrepareFlushResult	HRegion.internalPrepareFlushCache(WAL wal, long myseqid, Collection<HStore> storesToFlush, MonitoredTask status, boolean writeFlushWalMarker, FlushLifeCycleTracker tracker)
private boolean	HRegion.isAllFamilies(Collection<HStore> families)
private long	HRegion.loadRecoveredHFilesIfAny(Collection<HStore> stores)
private void	HRegion.logFatLineOnFlush(Collection<HStore> storesToFlush, long sequenceId) Utility method broken out of internalPrepareFlushCache so that method is smaller.

Constructors in org.apache.hadoop.hbase.regionserver with parameters of type HStore

Constructor and Description
CompactedHFilesDischargeHandler(Server server, EventType eventType, HStore store)
CompactingMemStore(org.apache.hadoop.conf.Configuration conf, CellComparator c, HStore store, RegionServicesForStores regionServices, MemoryCompactionPolicy compactionPolicy)
CompactionRunner(HStore store, HRegion region, CompactionContext compaction, CompactionLifeCycleTracker tracker, CompactSplit.CompactionCompleteTracker completeTracker, ThreadPoolExecutor parent, User user)
DefaultStoreFlusher(org.apache.hadoop.conf.Configuration conf, HStore store)
MemStoreCompactorSegmentsIterator(List<ImmutableSegment> segments, CellComparator comparator, int compactionKVMax, HStore store)
MobStoreScanner(HStore store, ScanInfo scanInfo, Scan scan, NavigableSet<byte[]> columns, long readPt)
ReversedMobStoreScanner(HStore store, ScanInfo scanInfo, Scan scan, NavigableSet<byte[]> columns, long readPt)
ReversedStoreScanner(HStore store, ScanInfo scanInfo, Scan scan, NavigableSet<byte[]> columns, long readPt) Opens a scanner across memstore, snapshot, and all StoreFiles.
StoreFlusher(org.apache.hadoop.conf.Configuration conf, HStore store)
StoreScanner(HStore store, ScanInfo scanInfo, List<? extends KeyValueScanner> scanners, long smallestReadPoint, long earliestPutTs, byte[] dropDeletesFromRow, byte[] dropDeletesToRow) Used for compactions that drop deletes from a limited range of rows.
StoreScanner(HStore store, ScanInfo scanInfo, List<? extends KeyValueScanner> scanners, ScanType scanType, long smallestReadPoint, long earliestPutTs) Used for store file compaction and memstore compaction.
StoreScanner(HStore store, ScanInfo scanInfo, List<? extends KeyValueScanner> scanners, ScanType scanType, long smallestReadPoint, long earliestPutTs, byte[] dropDeletesFromRow, byte[] dropDeletesToRow)
StoreScanner(HStore store, ScanInfo scanInfo, Scan scan, NavigableSet<byte[]> columns, long readPt) Opens a scanner across memstore, snapshot, and all StoreFiles.
StoreScanner(HStore store, Scan scan, ScanInfo scanInfo, int numColumns, long readPt, boolean cacheBlocks, ScanType scanType) An internal constructor.
StripeStoreFlusher(org.apache.hadoop.conf.Configuration conf, HStore store, StripeCompactionPolicy policy, StripeStoreFileManager stripes)

Uses of HStore in org.apache.hadoop.hbase.regionserver.compactions

Fields in org.apache.hadoop.hbase.regionserver.compactions declared as HStore

Modifier and Type	Field and Description
protected HStore	Compactor.store

Methods in org.apache.hadoop.hbase.regionserver.compactions with parameters of type HStore

Modifier and Type	Method and Description
protected InternalScanner	Compactor.createScanner(HStore store, ScanInfo scanInfo, List<StoreFileScanner> scanners, long smallestReadPoint, long earliestPutTs, byte[] dropDeletesFromRow, byte[] dropDeletesToRow)
protected InternalScanner	Compactor.createScanner(HStore store, ScanInfo scanInfo, List<StoreFileScanner> scanners, ScanType scanType, long smallestReadPoint, long earliestPutTs)
void	CompactionRequester.requestCompaction(HRegion region, HStore store, String why, int priority, CompactionLifeCycleTracker tracker, User user) Request compaction on the given store.

Constructors in org.apache.hadoop.hbase.regionserver.compactions with parameters of type HStore

Constructor and Description
AbstractMultiOutputCompactor(org.apache.hadoop.conf.Configuration conf, HStore store)
Compactor(org.apache.hadoop.conf.Configuration conf, HStore store)
DateTieredCompactor(org.apache.hadoop.conf.Configuration conf, HStore store)
DefaultCompactor(org.apache.hadoop.conf.Configuration conf, HStore store)
StripeCompactor(org.apache.hadoop.conf.Configuration conf, HStore store)

Uses of HStore in org.apache.hadoop.hbase.regionserver.throttle

Methods in org.apache.hadoop.hbase.regionserver.throttle with parameters of type HStore

Modifier and Type	Method and Description
static String	ThroughputControlUtil.getNameForThrottling(HStore store, String opName) Generate a name for throttling, to prevent name conflict when multiple IO operation running parallel on the same store.