org.apache.hadoop.hbase.util

Class MultiThreadedUpdaterWithACL

java.lang.Object

org.apache.hadoop.hbase.util.MultiThreadedAction

org.apache.hadoop.hbase.util.MultiThreadedWriterBase

org.apache.hadoop.hbase.util.MultiThreadedUpdater

org.apache.hadoop.hbase.util.MultiThreadedUpdaterWithACL

public class MultiThreadedUpdaterWithACL
extends MultiThreadedUpdater

A MultiThreadUpdater that helps to work with ACL

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
class	MultiThreadedUpdaterWithACL.HBaseUpdaterThreadWithACL

Nested classes/interfaces inherited from class org.apache.hadoop.hbase.util.MultiThreadedUpdater

MultiThreadedUpdater.HBaseUpdaterThread

Nested classes/interfaces inherited from class org.apache.hadoop.hbase.util.MultiThreadedAction

MultiThreadedAction.DefaultDataGenerator

Field Summary

Fields

Modifier and Type	Field and Description
private static String	COMMA
private static org.slf4j.Logger	LOG
private String[]	userNames
private org.apache.hadoop.hbase.security.User	userOwner
private Map<String,org.apache.hadoop.hbase.security.User>	users
private Map<String,org.apache.hadoop.hbase.client.Table>	userVsTable Maps user with Table instance.

Fields inherited from class org.apache.hadoop.hbase.util.MultiThreadedUpdater

updaters

Fields inherited from class org.apache.hadoop.hbase.util.MultiThreadedWriterBase

failedKeySet, nextKeyToWrite, trackWroteKeys, wroteKeyQueueSize, wroteKeys, wroteUpToKey

Fields inherited from class org.apache.hadoop.hbase.util.MultiThreadedAction

conf, connection, dataGenerator, endKey, numCols, numKeys, numThreads, numThreadsWorking, REPORTING_INTERVAL_MS, startKey, tableName, totalOpTimeMs, verbose

Constructor Summary

Constructors

Constructor and Description
MultiThreadedUpdaterWithACL(LoadTestDataGenerator dataGen, org.apache.hadoop.conf.Configuration conf, org.apache.hadoop.hbase.TableName tableName, double updatePercent, org.apache.hadoop.hbase.security.User userOwner, String userNames)

Method Summary

Modifier and Type	Method and Description
protected void	addUpdaterThreads(int numThreads)

Methods inherited from class org.apache.hadoop.hbase.util.MultiThreadedUpdater

linkToWriter, mutate, mutate, setBatchUpdate, setIgnoreNonceConflicts, start, waitForFinish

Methods inherited from class org.apache.hadoop.hbase.util.MultiThreadedWriterBase

createWriteKeysQueue, failedToWriteKey, getNumWriteFailures, getRegionDebugInfoSafe, progressInfo, setTrackWroteKeys, wroteUpToKey

Methods inherited from class org.apache.hadoop.hbase.util.MultiThreadedAction

appendToStatus, appendToStatus, close, getEndKey, isDone, startThreads, verifyResultAgainstDataGenerator, verifyResultAgainstDataGenerator

Methods inherited from class java.lang.Object

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

Field Detail

LOG

private static final org.slf4j.Logger LOG

COMMA

private static final String COMMA

See Also:

Constant Field Values

userOwner

private org.apache.hadoop.hbase.security.User userOwner

userVsTable

private Map<String,org.apache.hadoop.hbase.client.Table> userVsTable

Maps user with Table instance. Because the table instance has to be created per user inorder to work in that user's context

users

private Map<String,org.apache.hadoop.hbase.security.User> users

userNames

private String[] userNames

Constructor Detail

MultiThreadedUpdaterWithACL

public MultiThreadedUpdaterWithACL(LoadTestDataGenerator dataGen,
                                   org.apache.hadoop.conf.Configuration conf,
                                   org.apache.hadoop.hbase.TableName tableName,
                                   double updatePercent,
                                   org.apache.hadoop.hbase.security.User userOwner,
                                   String userNames)
                            throws IOException

Throws:

IOException

Method Detail

addUpdaterThreads

protected void addUpdaterThreads(int numThreads)
                          throws IOException

Overrides:

addUpdaterThreads in class MultiThreadedUpdater

Throws:

IOException