org.apache.hadoop.hbase

Class TestAcidGuarantees.AtomicGetReader

java.lang.Object

java.lang.Thread

org.apache.hadoop.hbase.MultithreadedTestUtil.TestThread

org.apache.hadoop.hbase.MultithreadedTestUtil.RepeatingTestThread

org.apache.hadoop.hbase.TestAcidGuarantees.AtomicGetReader

All Implemented Interfaces:

Runnable

Enclosing class:

TestAcidGuarantees

public static class TestAcidGuarantees.AtomicGetReader
extends MultithreadedTestUtil.RepeatingTestThread

Thread that does single-row reads in a table, looking for partially completed rows.

Nested Class Summary

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

Thread.State, Thread.UncaughtExceptionHandler

Field Summary

Fields inherited from class org.apache.hadoop.hbase.MultithreadedTestUtil.TestThread

ctx, stopped

Fields inherited from class java.lang.Thread

MAX_PRIORITY, MIN_PRIORITY, NORM_PRIORITY

Constructor Summary

Constructors

Constructor and Description
AtomicGetReader(MultithreadedTestUtil.TestContext ctx, byte[] targetRow, byte[][] targetFamilies)

Method Summary

Modifier and Type	Method and Description
void	doAnAction()

Methods inherited from class org.apache.hadoop.hbase.MultithreadedTestUtil.RepeatingTestThread

doWork

Methods inherited from class org.apache.hadoop.hbase.MultithreadedTestUtil.TestThread

run, stopTestThread

Methods inherited from class java.lang.Thread

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

Methods inherited from class java.lang.Object

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

Constructor Detail

AtomicGetReader

public AtomicGetReader(MultithreadedTestUtil.TestContext ctx,
                       byte[] targetRow,
                       byte[][] targetFamilies)
                throws IOException

Throws:

IOException

Method Detail

doAnAction

public void doAnAction()
                throws Exception

Specified by:

doAnAction in class MultithreadedTestUtil.RepeatingTestThread

Throws:

Exception