Package org.apache.hadoop.hbase.regionserver

Class TestWalAndCompactingMemStoreFlush.ConcurrentPutRunnable

java.lang.Object

org.apache.hadoop.hbase.regionserver.TestWalAndCompactingMemStoreFlush.ConcurrentPutRunnable

All Implemented Interfaces:

Runnable

Enclosing class:

TestWalAndCompactingMemStoreFlush

private class TestWalAndCompactingMemStoreFlush.ConcurrentPutRunnable
extends Object
implements Runnable

The in-memory-flusher thread performs the flush asynchronously. There is at most one thread per memstore instance. It takes the updatesLock exclusively, pushes active into the pipeline, releases updatesLock and compacts the pipeline.

Field Summary

Fields

Modifier and Type	Field	Description
private final int	startNumber
private final org.apache.hadoop.hbase.regionserver.HRegion	stressedRegion

Constructor Summary

Constructors

Constructor	Description
ConcurrentPutRunnable(org.apache.hadoop.hbase.regionserver.HRegion r, int i)

Method Summary

Modifier and Type	Method	Description
void	run()

Methods inherited from class java.lang.Object

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

Field Details

stressedRegion

private final org.apache.hadoop.hbase.regionserver.HRegion stressedRegion

startNumber

private final int startNumber

Constructor Details

ConcurrentPutRunnable

ConcurrentPutRunnable(org.apache.hadoop.hbase.regionserver.HRegion r,
 int i)

Method Details

run

public void run()

Specified by:

run in interface Runnable