public abstract class AbstractMemStore extends java.lang.Object implements MemStore
Modifier and Type | Field and Description |
---|---|
protected MutableSegment |
active |
static long |
DEEP_OVERHEAD |
static long |
FIXED_OVERHEAD |
protected ImmutableSegment |
snapshot |
protected long |
snapshotId |
Modifier | Constructor and Description |
---|---|
protected |
AbstractMemStore(Configuration conf,
CellComparator c) |
Modifier and Type | Method and Description |
---|---|
void |
add(Cell cell,
MemStoreSizing memstoreSizing)
Write an update
|
void |
add(java.lang.Iterable<Cell> cells,
MemStoreSizing memstoreSizing)
Write an update
|
static long |
addToScanners(java.util.List<? extends Segment> segments,
long readPt,
long order,
java.util.List<KeyValueScanner> scanners) |
protected static long |
addToScanners(Segment segment,
long readPt,
long order,
java.util.List<KeyValueScanner> scanners) |
protected abstract void |
checkActiveSize()
Check whether anything need to be done based on the current active set size
|
void |
clearSnapshot(long id)
The passed snapshot was successfully persisted; it can be let go.
|
protected void |
dump(Logger log) |
protected CellComparator |
getComparator() |
protected Configuration |
getConfiguration() |
protected Cell |
getLowest(Cell a,
Cell b) |
protected Cell |
getNextRow(Cell key,
java.util.NavigableSet<Cell> set) |
protected abstract java.util.List<Segment> |
getSegments() |
MemStoreSize |
getSnapshotSize()
Return the size of the snapshot(s) if any
|
protected abstract long |
heapSize() |
protected abstract long |
keySize() |
protected void |
resetActive() |
long |
timeOfOldestEdit() |
java.lang.String |
toString() |
abstract void |
updateLowestUnflushedSequenceIdInWAL(boolean onlyIfMoreRecent)
Updates the wal with the lowest sequence id (oldest entry) that is still in memory
|
void |
upsert(java.lang.Iterable<Cell> cells,
long readpoint,
MemStoreSizing memstoreSizing)
Update or insert the specified cells.
|
clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait
getFlushableSize, getScanners, isSloppy, preFlushSeqIDEstimation, size, snapshot, startReplayingFromWAL, stopReplayingFromWAL
protected volatile MutableSegment active
protected volatile ImmutableSegment snapshot
protected volatile long snapshotId
public static final long FIXED_OVERHEAD
public static final long DEEP_OVERHEAD
protected AbstractMemStore(Configuration conf, CellComparator c)
public static long addToScanners(java.util.List<? extends Segment> segments, long readPt, long order, java.util.List<KeyValueScanner> scanners)
protected static long addToScanners(Segment segment, long readPt, long order, java.util.List<KeyValueScanner> scanners)
protected void resetActive()
public abstract void updateLowestUnflushedSequenceIdInWAL(boolean onlyIfMoreRecent)
onlyIfMoreRecent
- a flag that marks whether to update the sequence id no matter what or
only if it is greater than the previous sequence idpublic void add(java.lang.Iterable<Cell> cells, MemStoreSizing memstoreSizing)
MemStore
public void add(Cell cell, MemStoreSizing memstoreSizing)
MemStore
public void upsert(java.lang.Iterable<Cell> cells, long readpoint, MemStoreSizing memstoreSizing)
MemStore
For each Cell, insert into MemStore. This will atomically upsert the value for that row/family/qualifier. If a Cell did already exist, it will then be removed.
Currently the memstoreTS is kept at 0 so as each insert happens, it will be immediately visible. May want to change this so it is atomic across all KeyValues.
This is called under row lock, so Get operations will still see updates atomically. Scans will only see each KeyValue update as atomic.
public long timeOfOldestEdit()
timeOfOldestEdit
in interface MemStore
public void clearSnapshot(long id) throws UnexpectedStateException
clearSnapshot
in interface MemStore
id
- Id of the snapshot to clean out.UnexpectedStateException
MemStore.snapshot()
public MemStoreSize getSnapshotSize()
MemStore
getSnapshotSize
in interface MemStore
public java.lang.String toString()
toString
in class java.lang.Object
protected Configuration getConfiguration()
protected void dump(Logger log)
protected Cell getLowest(Cell a, Cell b)
protected Cell getNextRow(Cell key, java.util.NavigableSet<Cell> set)
protected abstract long keySize()
protected abstract long heapSize()
protected CellComparator getComparator()
protected abstract void checkActiveSize()
protected abstract java.util.List<Segment> getSegments() throws java.io.IOException
java.io.IOException