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:

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 and Description
private AtomicInteger	clearSnapshotCounter
private static String	FLUSH_THREAD_NAME
private static String	GET_SCANNER_THREAD_NAME
private CyclicBarrier	getScannerCyclicBarrier Only when flush thread enters AbstractMemStore.doClearSnapShot(), getScanner thread could start.
private AtomicInteger	getSnapshotSegmentsCounter
private CyclicBarrier	postClearSnapShotCyclicBarrier Used by flush thread notifies getScanner thread AbstractMemStore.doClearSnapShot() completed, DefaultMemStore.getScanners(long) could continue.
private 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 and 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 and 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, 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 Detail

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 Detail

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 Detail

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