org.apache.hadoop.hbase.regionserver

Class TestHRegionServerBulkLoad.AtomicScanReader

java.lang.Object

java.lang.Thread

org.apache.hadoop.hbase.MultithreadedTestUtil.TestThread

org.apache.hadoop.hbase.MultithreadedTestUtil.RepeatingTestThread

org.apache.hadoop.hbase.regionserver.TestHRegionServerBulkLoad.AtomicScanReader

All Implemented Interfaces:

Runnable

Enclosing class:

TestHRegionServerBulkLoad

public static class TestHRegionServerBulkLoad.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) AtomicLong	numRowsScanned
(package private) AtomicLong	numScans
(package private) org.apache.hadoop.hbase.client.Table	table
(package private) org.apache.hadoop.hbase.TableName	TABLE_NAME
(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(org.apache.hadoop.hbase.TableName TABLE_NAME, MultithreadedTestUtil.TestContext ctx, byte[][] targetFamilies)

Method Summary

Modifier and Type	Method and Description
void	doAnAction()

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

doWork, workDone

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

numScans

AtomicLong numScans

numRowsScanned

AtomicLong numRowsScanned

TABLE_NAME

org.apache.hadoop.hbase.TableName TABLE_NAME

Constructor Detail

AtomicScanReader

public AtomicScanReader(org.apache.hadoop.hbase.TableName TABLE_NAME,
                        MultithreadedTestUtil.TestContext ctx,
                        byte[][] targetFamilies)
                 throws IOException

Throws:

IOException

Method Detail

doAnAction

public void doAnAction()
                throws Exception

Specified by:

doAnAction in class MultithreadedTestUtil.RepeatingTestThread

Throws:

Exception