org.apache.hadoop.hbase.util

Class MultiThreadedReaderWithACL

java.lang.Object

org.apache.hadoop.hbase.util.MultiThreadedAction

org.apache.hadoop.hbase.util.MultiThreadedReader

org.apache.hadoop.hbase.util.MultiThreadedReaderWithACL

public class MultiThreadedReaderWithACL
extends MultiThreadedReader

A MultiThreadReader that helps to work with ACL

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
class	MultiThreadedReaderWithACL.HBaseReaderThreadWithACL

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

MultiThreadedReader.HBaseReaderThread

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 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.MultiThreadedReader

aborted, DEFAULT_BATCH_SIZE, DEFAULT_KEY_WINDOW, DEFAULT_MAX_ERRORS, nullResult, numKeysVerified, numReadErrors, numReadFailures, readers, writer

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
MultiThreadedReaderWithACL(LoadTestDataGenerator dataGen, org.apache.hadoop.conf.Configuration conf, org.apache.hadoop.hbase.TableName tableName, double verifyPercent, String userNames)

Method Summary

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

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

createReaderThread, getNullResultsCount, getNumKeysVerified, getNumReadErrors, getNumReadFailures, getNumUniqueKeysVerified, linkToWriter, progressInfo, setKeyWindow, setMaxErrors, setMultiGetBatchSize, setRegionReplicaId, start

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

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

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

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

MultiThreadedReaderWithACL

public MultiThreadedReaderWithACL(LoadTestDataGenerator dataGen,
                                  org.apache.hadoop.conf.Configuration conf,
                                  org.apache.hadoop.hbase.TableName tableName,
                                  double verifyPercent,
                                  String userNames)
                           throws IOException

Throws:

IOException

Method Detail

addReaderThreads

protected void addReaderThreads(int numThreads)
                         throws IOException

Overrides:

addReaderThreads in class MultiThreadedReader

Throws:

IOException