Package org.apache.hadoop.hbase.util
Class MultiThreadedUpdater.HBaseUpdaterThread
java.lang.Object
java.lang.Thread
org.apache.hadoop.hbase.util.MultiThreadedUpdater.HBaseUpdaterThread
- All Implemented Interfaces:
Runnable
- Direct Known Subclasses:
MultiThreadedUpdaterWithACL.HBaseUpdaterThreadWithACL
- Enclosing class:
- MultiThreadedUpdater
-
Nested Class Summary
Nested classes/interfaces inherited from class java.lang.Thread
Thread.State, Thread.UncaughtExceptionHandler
-
Field Summary
Fields inherited from class java.lang.Thread
MAX_PRIORITY, MIN_PRIORITY, NORM_PRIORITY
-
Constructor Summary
-
Method Summary
Modifier and TypeMethodDescriptionprotected void
protected org.apache.hadoop.hbase.client.Table
protected org.apache.hadoop.hbase.client.Result
getRow
(org.apache.hadoop.hbase.client.Get get, long rowKeyBase, byte[] cf) void
mutate
(org.apache.hadoop.hbase.client.Table table, org.apache.hadoop.hbase.client.Mutation m, long keyBase) void
mutate
(org.apache.hadoop.hbase.client.Table table, org.apache.hadoop.hbase.client.Mutation m, long keyBase, byte[] row, byte[] cf, byte[] q, byte[] v) void
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
-
table
-
-
Constructor Details
-
HBaseUpdaterThread
- Throws:
IOException
-
-
Method Details
-
createTable
- Throws:
IOException
-
run
-
closeHTable
-
getRow
protected org.apache.hadoop.hbase.client.Result getRow(org.apache.hadoop.hbase.client.Get get, long rowKeyBase, byte[] cf) -
mutate
public void mutate(org.apache.hadoop.hbase.client.Table table, org.apache.hadoop.hbase.client.Mutation m, long keyBase) -
mutate
public void mutate(org.apache.hadoop.hbase.client.Table table, org.apache.hadoop.hbase.client.Mutation m, long keyBase, byte[] row, byte[] cf, byte[] q, byte[] v)
-