Package | Description |
---|---|
org.apache.hadoop.hbase.mob | |
org.apache.hadoop.hbase.regionserver | |
org.apache.hadoop.hbase.regionserver.compactions |
Modifier and Type | Method and Description |
---|---|
protected void |
MobStoreEngine.createCompactor(Configuration conf,
HStore store)
Creates the DefaultMobCompactor.
|
protected void |
MobStoreEngine.createStoreFlusher(Configuration conf,
HStore store) |
Constructor and Description |
---|
DefaultMobStoreCompactor(Configuration conf,
HStore store) |
DefaultMobStoreFlusher(Configuration conf,
HStore store) |
Modifier and Type | Class and Description |
---|---|
class |
HMobStore
The store implementation to save MOBs (medium objects), it extends the HStore.
|
Modifier and Type | Field and Description |
---|---|
protected HStore |
StoreScanner.store |
Modifier and Type | Field and Description |
---|---|
protected java.util.Map<byte[],HStore> |
HRegion.stores |
Modifier and Type | Method and Description |
---|---|
HStore |
CompactingMemStore.getStore() |
HStore |
HRegion.getStore(byte[] column) |
protected HStore |
HRegion.instantiateHStore(ColumnFamilyDescriptor family) |
Modifier and Type | Method and Description |
---|---|
java.util.List<HStore> |
HRegion.getStores() |
java.util.Collection<HStore> |
FlushNonSloppyStoresFirstPolicy.selectStoresToFlush() |
Modifier and Type | Method and Description |
---|---|
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,
Configuration conf,
CellComparator cellComparator)
Create the StoreEngine configured for the given Store.
|
protected abstract void |
StoreEngine.createComponents(Configuration conf,
HStore store,
CellComparator cellComparator)
Create the StoreEngine's components.
|
protected void |
DateTieredStoreEngine.createComponents(Configuration conf,
HStore store,
CellComparator kvComparator) |
protected StoreEngine<?,?,?,?> |
HMobStore.createStoreEngine(HStore store,
Configuration conf,
CellComparator cellComparator)
Creates the mob store engine.
|
protected StoreEngine<?,?,?,?> |
HStore.createStoreEngine(HStore store,
Configuration conf,
CellComparator kvComparator)
Creates the store engine configured for the given Store.
|
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,
java.util.List<HStoreFile> selected,
CompactionLifeCycleTracker tracker,
CompactionRequest request,
User user)
Called after the
HStoreFile s 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,
java.util.List<HStoreFile> candidates,
CompactionLifeCycleTracker tracker,
User user)
Called prior to selecting the
HStoreFile s 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)
Called before open store scanner for user scan.
|
void |
CompactSplit.requestCompaction(HRegion region,
HStore store,
java.lang.String why,
int priority,
CompactionLifeCycleTracker tracker,
User user) |
void |
CompactSplit.requestSystemCompaction(HRegion region,
HStore store,
java.lang.String why) |
protected void |
HRegion.restoreEdit(HStore s,
Cell cell,
MemStoreSizing memstoreAccounting)
Used by tests
|
protected java.util.List<KeyValueScanner> |
StoreScanner.selectScannersFrom(HStore store,
java.util.List<? extends KeyValueScanner> allScanners)
Filters the given list of scanners using Bloom filter, time range, and TTL.
|
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.
|
Modifier and Type | Method and Description |
---|---|
protected HRegion.FlushResultImpl |
HRegion.internalFlushcache(WAL wal,
long myseqid,
java.util.Collection<HStore> storesToFlush,
MonitoredTask status,
boolean writeFlushWalMarker,
FlushLifeCycleTracker tracker)
Flush the memstore.
|
protected HRegion.FlushResultImpl |
HRegion.internalFlushCacheAndCommit(WAL wal,
MonitoredTask status,
org.apache.hadoop.hbase.regionserver.HRegion.PrepareFlushResult prepareResult,
java.util.Collection<HStore> storesToFlush) |
protected org.apache.hadoop.hbase.regionserver.HRegion.PrepareFlushResult |
HRegion.internalPrepareFlushCache(WAL wal,
long myseqid,
java.util.Collection<HStore> storesToFlush,
MonitoredTask status,
boolean writeFlushWalMarker,
FlushLifeCycleTracker tracker) |
Constructor and Description |
---|
CompactedHFilesDischargeHandler(Server server,
EventType eventType,
HStore store) |
CompactingMemStore(Configuration conf,
CellComparator c,
HStore store,
RegionServicesForStores regionServices,
MemoryCompactionPolicy compactionPolicy) |
MemStoreCompactorSegmentsIterator(java.util.List<ImmutableSegment> segments,
CellComparator comparator,
int compactionKVMax,
HStore store) |
MobStoreScanner(HStore store,
ScanInfo scanInfo,
Scan scan,
java.util.NavigableSet<byte[]> columns,
long readPt) |
ReversedStoreScanner(HStore store,
ScanInfo scanInfo,
Scan scan,
java.util.NavigableSet<byte[]> columns,
long readPt)
Opens a scanner across memstore, snapshot, and all StoreFiles.
|
StoreScanner(HStore store,
ScanInfo scanInfo,
java.util.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,
java.util.List<? extends KeyValueScanner> scanners,
ScanType scanType,
long smallestReadPoint,
long earliestPutTs)
Used for store file compaction and memstore compaction.
|
StoreScanner(HStore store,
ScanInfo scanInfo,
Scan scan,
java.util.NavigableSet<byte[]> columns,
long readPt)
Opens a scanner across memstore, snapshot, and all StoreFiles.
|
StripeStoreFlusher(Configuration conf,
HStore store,
StripeCompactionPolicy policy,
StripeStoreFileManager stripes) |
Modifier and Type | Field and Description |
---|---|
protected HStore |
Compactor.store |
Modifier and Type | Method and Description |
---|---|
protected InternalScanner |
Compactor.createScanner(HStore store,
ScanInfo scanInfo,
java.util.List<StoreFileScanner> scanners,
long smallestReadPoint,
long earliestPutTs,
byte[] dropDeletesFromRow,
byte[] dropDeletesToRow) |
protected InternalScanner |
Compactor.createScanner(HStore store,
ScanInfo scanInfo,
java.util.List<StoreFileScanner> scanners,
ScanType scanType,
long smallestReadPoint,
long earliestPutTs) |
void |
CompactionRequester.requestCompaction(HRegion region,
HStore store,
java.lang.String why,
int priority,
CompactionLifeCycleTracker tracker,
User user)
Request compaction on the given store.
|
Constructor and Description |
---|
AbstractMultiOutputCompactor(Configuration conf,
HStore store) |
DateTieredCompactor(Configuration conf,
HStore store) |
DefaultCompactor(Configuration conf,
HStore store) |
StripeCompactor(Configuration conf,
HStore store) |