Uses of Class
org.apache.hadoop.hbase.regionserver.HStore
Package
Description
-
Uses of org.apache.hadoop.hbase.regionserver.HStore in org.apache.hadoop.hbase.mob
Modifier and TypeMethodDescriptionprotected 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) ModifierConstructorDescriptionDefaultMobStoreCompactor
(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
Modifier and TypeClassDescriptionclass
org.apache.hadoop.hbase.regionserver.HMobStore
The store implementation to save MOBs (medium objects), it extends the HStore.Modifier and TypeFieldDescriptionprotected 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
Modifier and TypeFieldDescriptionprotected final Map<byte[],
org.apache.hadoop.hbase.regionserver.HStore> HRegion.stores
Modifier and TypeMethodDescriptionorg.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) Modifier and TypeMethodDescriptionList<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.Modifier and TypeMethodDescriptionboolean
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 compactionvoid
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 theHStoreFile
s 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 flushvoid
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 compactionorg.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 theHStoreFile
s 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 flushorg.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 testsprotected 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) Modifier and TypeMethodDescriptionprotected 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) ModifierConstructorDescriptionCompactedHFilesDischargeHandler
(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