public class MultiThreadedUpdater extends MultiThreadedWriterBase
Modifier and Type | Class and Description |
---|---|
protected class |
MultiThreadedUpdater.HBaseUpdaterThread |
MultiThreadedAction.DefaultDataGenerator
Modifier and Type | Field and Description |
---|---|
protected java.util.Set<MultiThreadedUpdater.HBaseUpdaterThread> |
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 |
---|
MultiThreadedUpdater(LoadTestDataGenerator dataGen,
Configuration conf,
TableName tableName,
double updatePercent) |
Modifier and Type | Method and Description |
---|---|
protected void |
addUpdaterThreads(int numThreads) |
void |
linkToWriter(MultiThreadedWriterBase writer) |
void |
mutate(Table table,
Mutation m,
long keyBase) |
void |
mutate(Table table,
Mutation m,
long keyBase,
byte[] row,
byte[] cf,
byte[] q,
byte[] v) |
void |
setBatchUpdate(boolean isBatchUpdate)
Use batch vs.
|
void |
setIgnoreNonceConflicts(boolean value) |
void |
start(long startKey,
long endKey,
int numThreads) |
void |
waitForFinish() |
createWriteKeysQueue, failedToWriteKey, getNumWriteFailures, getRegionDebugInfoSafe, progressInfo, setTrackWroteKeys, wroteUpToKey
appendToStatus, appendToStatus, close, getEndKey, isDone, startThreads, verifyResultAgainstDataGenerator, verifyResultAgainstDataGenerator
protected java.util.Set<MultiThreadedUpdater.HBaseUpdaterThread> updaters
public MultiThreadedUpdater(LoadTestDataGenerator dataGen, Configuration conf, TableName tableName, double updatePercent) throws java.io.IOException
java.io.IOException
public void setBatchUpdate(boolean isBatchUpdate)
public void linkToWriter(MultiThreadedWriterBase writer)
public void start(long startKey, long endKey, int numThreads) throws java.io.IOException
start
in class MultiThreadedWriterBase
java.io.IOException
protected void addUpdaterThreads(int numThreads) throws java.io.IOException
java.io.IOException
public void waitForFinish()
waitForFinish
in class MultiThreadedAction
public void mutate(Table table, Mutation m, long keyBase)
public void mutate(Table table, Mutation m, long keyBase, byte[] row, byte[] cf, byte[] q, byte[] v)
public void setIgnoreNonceConflicts(boolean value)