org.apache.hadoop.hbase.regionserver

Class TestHRegionServerBulkLoad.AtomicHFileLoader

java.lang.Object

java.lang.Thread

org.apache.hadoop.hbase.MultithreadedTestUtil.TestThread

org.apache.hadoop.hbase.MultithreadedTestUtil.RepeatingTestThread

org.apache.hadoop.hbase.regionserver.TestHRegionServerBulkLoad.AtomicHFileLoader

All Implemented Interfaces:

Runnable

Enclosing class:

TestHRegionServerBulkLoad

public static class TestHRegionServerBulkLoad.AtomicHFileLoader
extends MultithreadedTestUtil.RepeatingTestThread

Thread that does full scans of the table looking for any partially completed rows. Each iteration of this loads 10 hdfs files, which occupies 5 file open file handles. So every 10 iterations (500 file handles) it does a region compaction to reduce the number of open file handles.

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	numBulkLoads
(package private) AtomicLong	numCompactions
private org.apache.hadoop.hbase.TableName	tableName

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
AtomicHFileLoader(org.apache.hadoop.hbase.TableName tableName, 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

numBulkLoads

final AtomicLong numBulkLoads

numCompactions

final AtomicLong numCompactions

tableName

private org.apache.hadoop.hbase.TableName tableName

Constructor Detail

AtomicHFileLoader

public AtomicHFileLoader(org.apache.hadoop.hbase.TableName tableName,
                         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