Package org.apache.hadoop.hbase.regionserver

Class TestHStore.MyDefaultMemStore

java.lang.Object

org.apache.hadoop.hbase.regionserver.AbstractMemStore

org.apache.hadoop.hbase.regionserver.DefaultMemStore

org.apache.hadoop.hbase.regionserver.TestHStore.MyDefaultMemStore

All Implemented Interfaces:

Closeable, AutoCloseable, org.apache.hadoop.hbase.regionserver.MemStore

Enclosing class:

TestHStore

public static class TestHStore.MyDefaultMemStore
extends org.apache.hadoop.hbase.regionserver.DefaultMemStore

Field Summary

Fields

Modifier and Type	Field	Description
private final AtomicInteger	clearSnapshotCounter
private static final String	FLUSH_THREAD_NAME
private static final String	GET_SCANNER_THREAD_NAME
private final CyclicBarrier	getScannerCyclicBarrier	Only when flush thread enters AbstractMemStore.doClearSnapShot(), getScanner thread could start.
private final AtomicInteger	getSnapshotSegmentsCounter
private final CyclicBarrier	postClearSnapShotCyclicBarrier	Used by flush thread notifies getScanner thread AbstractMemStore.doClearSnapShot() completed, DefaultMemStore.getScanners(long) could continue.
private final CyclicBarrier	preClearSnapShotCyclicBarrier	Used by getScanner thread notifies flush thread DefaultMemStore.getSnapshotSegments() completed, AbstractMemStore.doClearSnapShot() could continue.
private boolean	shouldWait
private org.apache.hadoop.hbase.regionserver.HStore	store

Fields inherited from class org.apache.hadoop.hbase.regionserver.DefaultMemStore

DEEP_OVERHEAD, FIXED_OVERHEAD

Fields inherited from class org.apache.hadoop.hbase.regionserver.AbstractMemStore

regionServices, snapshot, snapshotId

Constructor Summary

Constructors

Constructor	Description
MyDefaultMemStore(org.apache.hadoop.conf.Configuration conf, org.apache.hadoop.hbase.CellComparator cellComparator, org.apache.hadoop.hbase.regionserver.RegionServicesForStores regionServices)

Method Summary

Modifier and Type	Method	Description
protected void	doClearSnapShot()
protected List<org.apache.hadoop.hbase.regionserver.Segment>	getSnapshotSegments()

Methods inherited from class org.apache.hadoop.hbase.regionserver.DefaultMemStore

getFlushableSize, getNextRow, getScanners, getSegments, heapSize, isSloppy, keySize, main, postUpdate, preFlushSeqIDEstimation, preUpdate, size, sizeAddedPreOperation, snapshot, updateLowestUnflushedSequenceIdInWAL

Methods inherited from class org.apache.hadoop.hbase.regionserver.AbstractMemStore

add, add, addToScanners, addToScanners, clearSnapshot, close, doAdd, dump, getActive, getComparator, getConfiguration, getLowest, getNextRow, getSnapshot, getSnapshotSize, resetActive, resetTimeOfOldestEdit, timeOfOldestEdit, toString, upsert

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait

Methods inherited from interface org.apache.hadoop.hbase.regionserver.MemStore

startReplayingFromWAL, stopReplayingFromWAL

Field Details

GET_SCANNER_THREAD_NAME

private static final String GET_SCANNER_THREAD_NAME

See Also:

• Constant Field Values

FLUSH_THREAD_NAME

private static final String FLUSH_THREAD_NAME

See Also:

• Constant Field Values

getScannerCyclicBarrier

private final CyclicBarrier getScannerCyclicBarrier

Only when flush thread enters AbstractMemStore.doClearSnapShot(), getScanner thread could start.

preClearSnapShotCyclicBarrier

private final CyclicBarrier preClearSnapShotCyclicBarrier

Used by getScanner thread notifies flush thread DefaultMemStore.getSnapshotSegments() completed, AbstractMemStore.doClearSnapShot() could continue.

postClearSnapShotCyclicBarrier

private final CyclicBarrier postClearSnapShotCyclicBarrier

Used by flush thread notifies getScanner thread AbstractMemStore.doClearSnapShot() completed, DefaultMemStore.getScanners(long) could continue.

getSnapshotSegmentsCounter

private final AtomicInteger getSnapshotSegmentsCounter

clearSnapshotCounter

private final AtomicInteger clearSnapshotCounter

shouldWait

private volatile boolean shouldWait

store

private volatile org.apache.hadoop.hbase.regionserver.HStore store

Constructor Details

MyDefaultMemStore

public MyDefaultMemStore(org.apache.hadoop.conf.Configuration conf,
 org.apache.hadoop.hbase.CellComparator cellComparator,
 org.apache.hadoop.hbase.regionserver.RegionServicesForStores regionServices)
                  throws IOException

Throws:

IOException

Method Details

getSnapshotSegments

protected List<org.apache.hadoop.hbase.regionserver.Segment> getSnapshotSegments()

Overrides:

getSnapshotSegments in class org.apache.hadoop.hbase.regionserver.DefaultMemStore

doClearSnapShot

protected void doClearSnapShot()

Overrides:

doClearSnapShot in class org.apache.hadoop.hbase.regionserver.AbstractMemStore