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:

java.lang.Runnable

Enclosing class:

MultiThreadedUpdaterWithACL

public class MultiThreadedUpdaterWithACL.HBaseUpdaterThreadWithACL
extends MultiThreadedUpdater.HBaseUpdaterThread

Nested Class Summary

Nested classes/interfaces inherited from class java.lang.Thread

java.lang.Thread.State, java.lang.Thread.UncaughtExceptionHandler

Field Summary

Fields inherited from class java.lang.Thread

MAX_PRIORITY, MIN_PRIORITY, NORM_PRIORITY

Constructor Summary

Constructors

Constructor and Description
HBaseUpdaterThreadWithACL(int updaterId)

Method Summary

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)

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, 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

Methods inherited from class java.lang.Object

equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait

Constructor Detail

HBaseUpdaterThreadWithACL

public HBaseUpdaterThreadWithACL(int updaterId)
                          throws java.io.IOException

Throws:

java.io.IOException

Method Detail

createTable

protected HTableInterface createTable()
                               throws java.io.IOException

Overrides:

createTable in class MultiThreadedUpdater.HBaseUpdaterThread

Throws:

java.io.IOException

closeHTable

protected void closeHTable()

Overrides:

closeHTable in class MultiThreadedUpdater.HBaseUpdaterThread

getRow

protected Result getRow(Get get,
                        long rowKeyBase,
                        byte[] cf)

Overrides:

getRow in class MultiThreadedUpdater.HBaseUpdaterThread

mutate

public void mutate(Table table,
                   Mutation m,
                   long keyBase,
                   byte[] row,
                   byte[] cf,
                   byte[] q,
                   byte[] v)

Overrides:

mutate in class MultiThreadedUpdater.HBaseUpdaterThread