org.apache.hadoop.hbase

Class AcidGuaranteesTestTool.AtomicScanReader

java.lang.Object

java.lang.Thread

org.apache.hadoop.hbase.MultithreadedTestUtil.TestThread

org.apache.hadoop.hbase.MultithreadedTestUtil.RepeatingTestThread

org.apache.hadoop.hbase.AcidGuaranteesTestTool.AtomicScanReader

All Implemented Interfaces:

Runnable

Enclosing class:

AcidGuaranteesTestTool

public static class AcidGuaranteesTestTool.AtomicScanReader
extends MultithreadedTestUtil.RepeatingTestThread

Thread that does full scans of the table looking for any partially completed rows.

Nested Class Summary

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

Thread.State, Thread.UncaughtExceptionHandler

Field Summary

Fields

Modifier and Type	Field and Description
(package private) org.apache.hadoop.hbase.client.Connection	connection
(package private) AtomicLong	numRowsScanned
(package private) AtomicLong	numScans
(package private) org.apache.hadoop.hbase.client.Table	table
(package private) byte[][]	targetFamilies

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
AtomicScanReader(MultithreadedTestUtil.TestContext ctx, byte[][] targetFamilies, ExecutorService pool)

Method Summary

Modifier and Type	Method and Description
void	doAnAction()
private void	gotFailure(byte[] expected, org.apache.hadoop.hbase.client.Result res)
void	workDone()

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

Field Detail

targetFamilies

byte[][] targetFamilies

table

org.apache.hadoop.hbase.client.Table table

connection

org.apache.hadoop.hbase.client.Connection connection

numScans

AtomicLong numScans

numRowsScanned

AtomicLong numRowsScanned

Constructor Detail

AtomicScanReader

public AtomicScanReader(MultithreadedTestUtil.TestContext ctx,
                        byte[][] targetFamilies,
                        ExecutorService pool)
                 throws IOException

Throws:

IOException

Method Detail

doAnAction

public void doAnAction()
                throws Exception

Specified by:

doAnAction in class MultithreadedTestUtil.RepeatingTestThread

Throws:

Exception

workDone

public void workDone()
              throws IOException

Overrides:

workDone in class MultithreadedTestUtil.RepeatingTestThread

Throws:

IOException

gotFailure

private void gotFailure(byte[] expected,
                        org.apache.hadoop.hbase.client.Result res)