public class MultiThreadedWriter.HBaseWriterThread
extends java.lang.Thread
Constructor and Description |
---|
HBaseWriterThread(int writerId) |
Modifier and Type | Method and Description |
---|---|
protected void |
closeHTable() |
protected HTableInterface |
createTable() |
void |
insert(Table table,
Put put,
long keyBase) |
void |
run() |
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
public HBaseWriterThread(int writerId) throws java.io.IOException
java.io.IOException
protected HTableInterface createTable() throws java.io.IOException
java.io.IOException
public void run()
run
in interface java.lang.Runnable
run
in class java.lang.Thread
public void insert(Table table, Put put, long keyBase)
protected void closeHTable()