org.apache.hadoop.hbase.util

Class MultiThreadedWriterWithACL

java.lang.Object

org.apache.hadoop.hbase.util.MultiThreadedAction

org.apache.hadoop.hbase.util.MultiThreadedWriterBase

org.apache.hadoop.hbase.util.MultiThreadedWriter

org.apache.hadoop.hbase.util.MultiThreadedWriterWithACL

public class MultiThreadedWriterWithACL
extends MultiThreadedWriter

MultiThreadedWriter that helps in testing ACL

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
class	MultiThreadedWriterWithACL.HBaseWriterThreadWithACL

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

MultiThreadedWriter.HBaseWriterThread

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 org.slf4j.Logger	LOG
private org.apache.hadoop.hbase.security.User	userOwner

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

isMultiPut, writers

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
MultiThreadedWriterWithACL(LoadTestDataGenerator dataGen, org.apache.hadoop.conf.Configuration conf, org.apache.hadoop.hbase.TableName tableName, org.apache.hadoop.hbase.security.User userOwner)

Method Summary

Modifier and Type	Method and Description
protected void	createWriterThreads(int numThreads)
private void	recordFailure(org.apache.hadoop.hbase.client.Table table, org.apache.hadoop.hbase.client.Put put, long keyBase, long start, IOException e)
void	start(long startKey, long endKey, int numThreads)

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

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

userOwner

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

Constructor Detail

MultiThreadedWriterWithACL

public MultiThreadedWriterWithACL(LoadTestDataGenerator dataGen,
                                  org.apache.hadoop.conf.Configuration conf,
                                  org.apache.hadoop.hbase.TableName tableName,
                                  org.apache.hadoop.hbase.security.User userOwner)
                           throws IOException

Throws:

IOException

Method Detail

start

public void start(long startKey,
                  long endKey,
                  int numThreads)
           throws IOException

Overrides:

start in class MultiThreadedWriter

Throws:

IOException

createWriterThreads

protected void createWriterThreads(int numThreads)
                            throws IOException

Overrides:

createWriterThreads in class MultiThreadedWriter

Throws:

IOException

recordFailure

private void recordFailure(org.apache.hadoop.hbase.client.Table table,
                           org.apache.hadoop.hbase.client.Put put,
                           long keyBase,
                           long start,
                           IOException e)