public class MultiThreadedWriterWithACL extends MultiThreadedWriter
| Modifier and Type | Class and Description |
|---|---|
class |
MultiThreadedWriterWithACL.HBaseWriterThreadWithACL |
MultiThreadedWriter.HBaseWriterThreadMultiThreadedAction.DefaultDataGeneratorisMultiPut, writersfailedKeySet, nextKeyToWrite, trackWroteKeys, wroteKeyQueueSize, wroteKeys, wroteUpToKeyconf, 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, waitForFinishcreateWriteKeysQueue, failedToWriteKey, getNumWriteFailures, getRegionDebugInfoSafe, progressInfo, setTrackWroteKeys, wroteUpToKeyappendToStatus, appendToStatus, close, getEndKey, isDone, startThreads, verifyResultAgainstDataGenerator, verifyResultAgainstDataGeneratorpublic MultiThreadedWriterWithACL(LoadTestDataGenerator dataGen, Configuration conf, TableName tableName, User userOwner) throws IOException
IOExceptionpublic void start(long startKey,
long endKey,
int numThreads)
throws IOException
start in class MultiThreadedWriterIOExceptionprotected void createWriterThreads(int numThreads)
throws IOException
createWriterThreads in class MultiThreadedWriterIOException