org.apache.hadoop.hbase.util

Class MultiThreadedWriter

java.lang.Object

org.apache.hadoop.hbase.util.MultiThreadedAction

org.apache.hadoop.hbase.util.MultiThreadedWriterBase

org.apache.hadoop.hbase.util.MultiThreadedWriter

Direct Known Subclasses:

IntegrationTestRegionReplicaReplication.DelayingMultiThreadedWriter, MultiThreadedWriterWithACL

public class MultiThreadedWriter
extends MultiThreadedWriterBase

Creates multiple threads that write key/values into the

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
class	MultiThreadedWriter.HBaseWriterThread

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

MultiThreadedAction.DefaultDataGenerator

Field Summary

Fields

Modifier and Type	Field and Description
protected boolean	isMultiPut
private static org.slf4j.Logger	LOG
protected Set<MultiThreadedWriter.HBaseWriterThread>	writers

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 and Description
MultiThreadedWriter(LoadTestDataGenerator dataGen, org.apache.hadoop.conf.Configuration conf, org.apache.hadoop.hbase.TableName tableName)

Method Summary

Modifier and Type	Method and Description
protected void	createWriterThreads(int numThreads)
void	setMultiPut(boolean isMultiPut) Use multi-puts vs.
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 Detail

LOG

private static final org.slf4j.Logger LOG

writers

protected Set<MultiThreadedWriter.HBaseWriterThread> writers

isMultiPut

protected boolean isMultiPut

Constructor Detail

MultiThreadedWriter

public MultiThreadedWriter(LoadTestDataGenerator dataGen,
                           org.apache.hadoop.conf.Configuration conf,
                           org.apache.hadoop.hbase.TableName tableName)
                    throws IOException

Throws:

IOException

Method Detail

setMultiPut

public void setMultiPut(boolean isMultiPut)

Use multi-puts vs. separate puts for every column in a row

start

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

Overrides:

start in class MultiThreadedWriterBase

Throws:

IOException

createWriterThreads

protected void createWriterThreads(int numThreads)
                            throws IOException

Throws:

IOException

waitForFinish

public void waitForFinish()

Overrides:

waitForFinish in class MultiThreadedAction