Package org.apache.hadoop.hbase.regionserver

Class TestHRegion.PutThread

java.lang.Object

java.lang.Thread

org.apache.hadoop.hbase.regionserver.TestHRegion.PutThread

All Implemented Interfaces:

Runnable

Enclosing class:

TestHRegion

protected class TestHRegion.PutThread
extends Thread

Nested Class Summary

Nested classes/interfaces inherited from class java.lang.Thread

Thread.State, Thread.UncaughtExceptionHandler

Field Summary

Fields

Modifier and Type	Field	Description
private boolean	done
private Throwable	error
private byte[][]	families
private int	numPutsFinished
private int	numRows
private byte[][]	qualifiers

Fields inherited from class java.lang.Thread

MAX_PRIORITY, MIN_PRIORITY, NORM_PRIORITY

Constructor Summary

Constructors

Modifier	Constructor	Description
private	PutThread(int numRows, byte[][] families, byte[][] qualifiers)

Method Summary

Modifier and Type	Method	Description
void	checkNoError()
void	done()
void	run()
void	waitForFirstPut()	Block calling thread until this instance of PutThread has put at least one row.

Methods inherited from class java.lang.Thread

activeCount, checkAccess, clone, countStackFrames, currentThread, dumpStack, enumerate, getAllStackTraces, getContextClassLoader, getDefaultUncaughtExceptionHandler, getId, getName, getPriority, getStackTrace, getState, getThreadGroup, getUncaughtExceptionHandler, holdsLock, interrupt, interrupted, isAlive, isDaemon, isInterrupted, join, join, join, onSpinWait, resume, setContextClassLoader, setDaemon, setDefaultUncaughtExceptionHandler, setName, setPriority, setUncaughtExceptionHandler, sleep, sleep, start, stop, suspend, toString, yield

Methods inherited from class java.lang.Object

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

Field Details

done

private volatile boolean done

numPutsFinished

private volatile int numPutsFinished

error

private Throwable error

numRows

private int numRows

families

private byte[][] families

qualifiers

private byte[][] qualifiers

Constructor Details

PutThread

private PutThread(int numRows,
 byte[][] families,
 byte[][] qualifiers)

Method Details

waitForFirstPut

public void waitForFirstPut()
                     throws InterruptedException

Block calling thread until this instance of PutThread has put at least one row.

Throws:

InterruptedException

done

public void done()

checkNoError

public void checkNoError()

run

public void run()

Specified by:

run in interface Runnable

Overrides:

run in class Thread