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

public class MultiThreadedUpdaterWithACL.HBaseUpdaterThreadWithACL
extends MultiThreadedUpdater.HBaseUpdaterThread

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
(package private) class	MultiThreadedUpdaterWithACL.HBaseUpdaterThreadWithACL.MutateAccessAction

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

Thread.State, Thread.UncaughtExceptionHandler

Field Summary

Fields

Modifier and Type	Field and Description
private MultiThreadedUpdaterWithACL.HBaseUpdaterThreadWithACL.MutateAccessAction	mutateAction
private org.apache.hadoop.hbase.client.Table	table

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 org.apache.hadoop.hbase.client.Table	createTable()
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, byte[] row, byte[] cf, byte[] q, byte[] v)
private void	recordFailure(org.apache.hadoop.hbase.client.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, 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

Field Detail

table

private org.apache.hadoop.hbase.client.Table table

mutateAction

private MultiThreadedUpdaterWithACL.HBaseUpdaterThreadWithACL.MutateAccessAction mutateAction

Constructor Detail

HBaseUpdaterThreadWithACL

public HBaseUpdaterThreadWithACL(int updaterId)
                          throws IOException

Throws:

IOException

Method Detail

createTable

protected org.apache.hadoop.hbase.client.Table createTable()
                                                    throws IOException

Overrides:

createTable in class MultiThreadedUpdater.HBaseUpdaterThread

Throws:

IOException

closeHTable

protected void closeHTable()

Overrides:

closeHTable in class MultiThreadedUpdater.HBaseUpdaterThread

getRow

protected org.apache.hadoop.hbase.client.Result getRow(org.apache.hadoop.hbase.client.Get get,
                                                       long rowKeyBase,
                                                       byte[] cf)

Overrides:

getRow in class MultiThreadedUpdater.HBaseUpdaterThread

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)

Overrides:

mutate in class MultiThreadedUpdater.HBaseUpdaterThread

recordFailure

private void recordFailure(org.apache.hadoop.hbase.client.Mutation m,
                           long keyBase,
                           long start,
                           IOException e)