public class MultiThreadedUpdaterWithACL.HBaseUpdaterThreadWithACL extends MultiThreadedUpdater.HBaseUpdaterThread
Constructor and Description |
---|
HBaseUpdaterThreadWithACL(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,
byte[] row,
byte[] cf,
byte[] q,
byte[] v) |
mutate, 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 HBaseUpdaterThreadWithACL(int updaterId) throws java.io.IOException
java.io.IOException
protected HTableInterface createTable() throws java.io.IOException
createTable
in class MultiThreadedUpdater.HBaseUpdaterThread
java.io.IOException
protected void closeHTable()
closeHTable
in class MultiThreadedUpdater.HBaseUpdaterThread
protected Result getRow(Get get, long rowKeyBase, byte[] cf)
getRow
in class MultiThreadedUpdater.HBaseUpdaterThread
public void mutate(Table table, Mutation m, long keyBase, byte[] row, byte[] cf, byte[] q, byte[] v)
mutate
in class MultiThreadedUpdater.HBaseUpdaterThread