Package 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	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	Description
private static final String	COMMA
private static final 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	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	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 Details

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 Details

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 Details

addReaderThreads

protected void addReaderThreads(int numThreads)
                         throws IOException

Overrides:

addReaderThreads in class MultiThreadedReader

Throws:

IOException