protected class MultiThreadedUpdater.HBaseUpdaterThread
extends java.lang.Thread
Modifier and Type | Field and Description |
---|---|
protected Table |
table |
Constructor and Description |
---|
HBaseUpdaterThread(int updaterId) |
Modifier and Type | Method and Description |
---|---|
protected void |
closeHTable() |
protected HTableInterface |
createTable() |
protected Result |
getRow(Get get,
long rowKeyBase,
byte[] cf) |
void |
mutate(Table table,
Mutation m,
long keyBase) |
void |
mutate(Table table,
Mutation m,
long keyBase,
byte[] row,
byte[] cf,
byte[] q,
byte[] v) |
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 HBaseUpdaterThread(int updaterId) 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
protected void closeHTable()
protected Result getRow(Get get, long rowKeyBase, byte[] cf)
public void mutate(Table table, Mutation m, long keyBase)
public void mutate(Table table, Mutation m, long keyBase, byte[] row, byte[] cf, byte[] q, byte[] v)