Package org.apache.hadoop.hbase.util
Class MultiThreadedUpdaterWithACL.HBaseUpdaterThreadWithACL
java.lang.Object
java.lang.Thread
org.apache.hadoop.hbase.util.MultiThreadedUpdater.HBaseUpdaterThread
org.apache.hadoop.hbase.util.MultiThreadedUpdaterWithACL.HBaseUpdaterThreadWithACL
- All Implemented Interfaces:
Runnable
- Enclosing class:
- MultiThreadedUpdaterWithACL
-
Nested Class Summary
Modifier and TypeClassDescription(package private) class
Nested classes/interfaces inherited from class java.lang.Thread
Thread.State, Thread.UncaughtExceptionHandler
-
Field Summary
Modifier and TypeFieldDescriptionFields inherited from class org.apache.hadoop.hbase.util.MultiThreadedUpdater.HBaseUpdaterThread
table
Fields inherited from class java.lang.Thread
MAX_PRIORITY, MIN_PRIORITY, NORM_PRIORITY
-
Constructor Summary
-
Method Summary
Modifier and TypeMethodDescriptionprotected void
protected Table
protected Result
void
private void
recordFailure
(Mutation m, long keyBase, long start, IOException e) Methods inherited from class org.apache.hadoop.hbase.util.MultiThreadedUpdater.HBaseUpdaterThread
mutate, run
Methods inherited from class java.lang.Thread
activeCount, checkAccess, clone, countStackFrames, currentThread, dumpStack, enumerate, getAllStackTraces, getContextClassLoader, getDefaultUncaughtExceptionHandler, getId, getName, getPriority, getStackTrace, getState, getThreadGroup, getUncaughtExceptionHandler, holdsLock, interrupt, interrupted, isAlive, isDaemon, isInterrupted, join, join, join, onSpinWait, resume, setContextClassLoader, setDaemon, setDefaultUncaughtExceptionHandler, setName, setPriority, setUncaughtExceptionHandler, sleep, sleep, start, stop, suspend, toString, yield
-
Field Details
-
mutateAction
-
-
Constructor Details
-
HBaseUpdaterThreadWithACL
- Throws:
IOException
-
-
Method Details
-
createTable
- Overrides:
createTable
in classMultiThreadedUpdater.HBaseUpdaterThread
- Throws:
IOException
-
closeHTable
- Overrides:
closeHTable
in classMultiThreadedUpdater.HBaseUpdaterThread
-
getRow
- Overrides:
getRow
in classMultiThreadedUpdater.HBaseUpdaterThread
-
mutate
public void mutate(Table table, Mutation m, long keyBase, byte[] row, byte[] cf, byte[] q, byte[] v) - Overrides:
mutate
in classMultiThreadedUpdater.HBaseUpdaterThread
-
recordFailure
-