public class MultiThreadedWriterWithACL extends MultiThreadedWriter
Modifier and Type | Class and Description |
---|---|
class |
MultiThreadedWriterWithACL.HBaseWriterThreadWithACL |
MultiThreadedWriter.HBaseWriterThread
MultiThreadedAction.DefaultDataGenerator
isMultiPut, writers
failedKeySet, nextKeyToWrite, trackWroteKeys, wroteKeyQueueSize, wroteKeys, wroteUpToKey
conf, connection, dataGenerator, endKey, numCols, numKeys, numThreads, numThreadsWorking, REPORTING_INTERVAL_MS, startKey, tableName, totalOpTimeMs, verbose
Constructor and Description |
---|
MultiThreadedWriterWithACL(LoadTestDataGenerator dataGen,
Configuration conf,
TableName tableName,
User userOwner) |
Modifier and Type | Method and Description |
---|---|
protected void |
createWriterThreads(int numThreads) |
void |
start(long startKey,
long endKey,
int numThreads) |
setMultiPut, waitForFinish
createWriteKeysQueue, failedToWriteKey, getNumWriteFailures, getRegionDebugInfoSafe, progressInfo, setTrackWroteKeys, wroteUpToKey
appendToStatus, appendToStatus, close, getEndKey, isDone, startThreads, verifyResultAgainstDataGenerator, verifyResultAgainstDataGenerator
public MultiThreadedWriterWithACL(LoadTestDataGenerator dataGen, Configuration conf, TableName tableName, User userOwner) throws java.io.IOException
java.io.IOException
public void start(long startKey, long endKey, int numThreads) throws java.io.IOException
start
in class MultiThreadedWriter
java.io.IOException
protected void createWriterThreads(int numThreads) throws java.io.IOException
createWriterThreads
in class MultiThreadedWriter
java.io.IOException