Package org.apache.hadoop.hbase.util

Class MultiThreadedUpdater

java.lang.Object

org.apache.hadoop.hbase.util.MultiThreadedAction

org.apache.hadoop.hbase.util.MultiThreadedWriterBase

org.apache.hadoop.hbase.util.MultiThreadedUpdater

Direct Known Subclasses:

MultiThreadedUpdaterWithACL

@Private
public class MultiThreadedUpdater
extends MultiThreadedWriterBase

Creates multiple threads that write key/values into the

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
protected class	MultiThreadedUpdater.HBaseUpdaterThread

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

MultiThreadedAction.DefaultDataGenerator

Field Summary

Fields

Modifier and Type	Field	Description
private boolean	ignoreNonceConflicts
private boolean	isBatchUpdate
private static final org.slf4j.Logger	LOG
private final double	updatePercent
protected Set<MultiThreadedUpdater.HBaseUpdaterThread>	updaters
private MultiThreadedWriterBase	writer

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	Description
MultiThreadedUpdater(LoadTestDataGenerator dataGen, org.apache.hadoop.conf.Configuration conf, TableName tableName, double updatePercent)

Method Summary

Modifier and Type	Method	Description
protected void	addUpdaterThreads(int numThreads)
private long	getNextKeyToUpdate()
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()

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 Details

LOG

private static final org.slf4j.Logger LOG

updaters

protected Set<MultiThreadedUpdater.HBaseUpdaterThread> updaters

writer

private MultiThreadedWriterBase writer

isBatchUpdate

private boolean isBatchUpdate

ignoreNonceConflicts

private boolean ignoreNonceConflicts

updatePercent

private final double updatePercent

Constructor Details

MultiThreadedUpdater

public MultiThreadedUpdater(LoadTestDataGenerator dataGen,
 org.apache.hadoop.conf.Configuration conf,
 TableName tableName,
 double updatePercent)
                     throws IOException

Throws:

IOException

Method Details

setBatchUpdate

public void setBatchUpdate(boolean isBatchUpdate)

Use batch vs. separate updates for every column in a row

linkToWriter

public void linkToWriter(MultiThreadedWriterBase writer)

start

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

Overrides:

start in class MultiThreadedWriterBase

Throws:

IOException

addUpdaterThreads

protected void addUpdaterThreads(int numThreads)
                          throws IOException

Throws:

IOException

getNextKeyToUpdate

private long getNextKeyToUpdate()

waitForFinish

public void waitForFinish()

Overrides:

waitForFinish in class MultiThreadedAction

mutate

public void mutate(Table table,
 Mutation m,
 long keyBase)

mutate

public void mutate(Table table,
 Mutation m,
 long keyBase,
 byte[] row,
 byte[] cf,
 byte[] q,
 byte[] v)

setIgnoreNonceConflicts

public void setIgnoreNonceConflicts(boolean value)