Package | Description |
---|---|
org.apache.hadoop.hbase.regionserver |
Modifier and Type | Field and Description |
---|---|
private MemStoreSize |
MemStoreSnapshot.memStoreSize |
Modifier and Type | Field and Description |
---|---|
(package private) TreeMap<byte[],MemStoreSize> |
HRegion.PrepareFlushResult.storeFlushableSize |
Modifier and Type | Method and Description |
---|---|
private MemStoreSize |
HRegion.doDropStoreMemStoreContentsForSeqId(HStore s,
long currentSeqId) |
MemStoreSize |
HRegion.dropMemStoreContents()
Be careful, this method will drop all data in the memstore of this region.
|
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
|
MemStoreSize |
CompactingMemStore.getFlushableSize() |
MemStoreSize |
DefaultMemStore.getFlushableSize() |
MemStoreSize |
HStore.getFlushableSize() |
MemStoreSize |
Store.getFlushableSize() |
MemStoreSize |
MemStore.getFlushableSize()
Flush will first clear out the data in snapshot if any (It will take a second flush
invocation to clear the current Cell set).
|
MemStoreSize |
MemStoreSnapshot.getMemStoreSize() |
MemStoreSize |
Segment.getMemStoreSize() |
MemStoreSize |
HStore.getMemStoreSize() |
MemStoreSize |
NonThreadSafeMemStoreSizing.getMemStoreSize() |
MemStoreSize |
Store.getMemStoreSize() |
MemStoreSize |
MemStoreSizing.getMemStoreSize() |
MemStoreSize |
ThreadSafeMemStoreSizing.getMemStoreSize() |
MemStoreSize |
CompactionPipeline.getPipelineSize() |
MemStoreSize |
HStore.getSnapshotSize() |
MemStoreSize |
AbstractMemStore.getSnapshotSize() |
MemStoreSize |
Store.getSnapshotSize() |
MemStoreSize |
MemStore.getSnapshotSize()
Return the size of the snapshot(s) if any
|
MemStoreSize |
CompactionPipeline.getTailSize() |
MemStoreSize |
HStore.StoreFlusherImpl.prepare()
This is not thread safe.
|
MemStoreSize |
StoreFlushContext.prepare()
Prepare for a store flush (create snapshot)
Requires pausing writes.
|
MemStoreSize |
CompactingMemStore.size() |
MemStoreSize |
DefaultMemStore.size() |
MemStoreSize |
MemStore.size() |
Modifier and Type | Method and Description |
---|---|
default long |
MemStoreSizing.decMemStoreSize(MemStoreSize delta) |
(package private) void |
HRegion.decrMemStoreSize(MemStoreSize mss) |
(package private) void |
RegionServerAccounting.incGlobalMemStoreSize(MemStoreSize mss) |
(package private) void |
HRegion.incMemStoreSize(MemStoreSize mss)
Increase the size of mem store in this region and the size of global mem
store
|
default long |
MemStoreSizing.incMemStoreSize(MemStoreSize delta) |
private boolean |
HRegion.isFlushSize(MemStoreSize size) |
Constructor and Description |
---|
MemStoreSize(MemStoreSize memStoreSize)
Package private constructor.
|
NonThreadSafeMemStoreSizing(MemStoreSize mss) |
ThreadSafeMemStoreSizing(MemStoreSize mss) |
Constructor and Description |
---|
PrepareFlushResult(HRegion.FlushResultImpl result,
TreeMap<byte[],StoreFlushContext> storeFlushCtxs,
TreeMap<byte[],List<org.apache.hadoop.fs.Path>> committedFiles,
TreeMap<byte[],MemStoreSize> storeFlushableSize,
long startTime,
long flushSeqId,
long flushedSeqId,
MemStoreSizing totalFlushableSize) |
PrepareFlushResult(TreeMap<byte[],StoreFlushContext> storeFlushCtxs,
TreeMap<byte[],List<org.apache.hadoop.fs.Path>> committedFiles,
TreeMap<byte[],MemStoreSize> storeFlushableSize,
long startTime,
long flushSeqId,
long flushedSeqId,
MemStoreSizing totalFlushableSize)
Constructs a successful prepare flush result
|
Copyright © 2007–2019 The Apache Software Foundation. All rights reserved.