public class MultiThreadedUpdaterWithACL extends MultiThreadedUpdater
Modifier and Type | Class and Description |
---|---|
class |
MultiThreadedUpdaterWithACL.HBaseUpdaterThreadWithACL |
MultiThreadedUpdater.HBaseUpdaterThread
MultiThreadedAction.DefaultDataGenerator
updaters
failedKeySet, nextKeyToWrite, trackWroteKeys, wroteKeyQueueSize, wroteKeys, wroteUpToKey
conf, connection, dataGenerator, endKey, numCols, numKeys, numThreads, numThreadsWorking, REPORTING_INTERVAL_MS, startKey, tableName, totalOpTimeMs, verbose
Constructor and Description |
---|
MultiThreadedUpdaterWithACL(LoadTestDataGenerator dataGen,
Configuration conf,
TableName tableName,
double updatePercent,
User userOwner,
String userNames) |
Modifier and Type | Method and Description |
---|---|
protected void |
addUpdaterThreads(int numThreads) |
linkToWriter, mutate, mutate, setBatchUpdate, setIgnoreNonceConflicts, start, waitForFinish
createWriteKeysQueue, failedToWriteKey, getNumWriteFailures, getRegionDebugInfoSafe, progressInfo, setTrackWroteKeys, wroteUpToKey
appendToStatus, appendToStatus, close, getEndKey, isDone, startThreads, verifyResultAgainstDataGenerator, verifyResultAgainstDataGenerator
public MultiThreadedUpdaterWithACL(LoadTestDataGenerator dataGen, Configuration conf, TableName tableName, double updatePercent, User userOwner, String userNames) throws IOException
IOException
protected void addUpdaterThreads(int numThreads) throws IOException
addUpdaterThreads
in class MultiThreadedUpdater
IOException