org.apache.hadoop.hbase

Class IntegrationTestRegionReplicaReplication.DelayingMultiThreadedWriter

java.lang.Object

org.apache.hadoop.hbase.util.MultiThreadedAction

org.apache.hadoop.hbase.util.MultiThreadedWriterBase

org.apache.hadoop.hbase.util.MultiThreadedWriter

org.apache.hadoop.hbase.IntegrationTestRegionReplicaReplication.DelayingMultiThreadedWriter

Enclosing class:

IntegrationTestRegionReplicaReplication

public static class IntegrationTestRegionReplicaReplication.DelayingMultiThreadedWriter
extends MultiThreadedWriter

This extends MultiThreadedWriter to add a configurable delay to the keys written by the writer threads to become available to the MultiThradedReader threads. We add this delay because of the async nature of the wal replication to region replicas.

Nested Class Summary

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

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
private long	delayMs

Fields inherited from class org.apache.hadoop.hbase.util.MultiThreadedWriter

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

Method Summary

Modifier and Type	Method and Description
protected BlockingQueue<Long>	createWriteKeysQueue(org.apache.hadoop.conf.Configuration conf)

Methods inherited from class org.apache.hadoop.hbase.util.MultiThreadedWriter

createWriterThreads, setMultiPut, start, waitForFinish

Methods inherited from class org.apache.hadoop.hbase.util.MultiThreadedWriterBase

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

delayMs

private long delayMs

Constructor Detail

DelayingMultiThreadedWriter

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

Throws:

IOException

Method Detail

createWriteKeysQueue

protected BlockingQueue<Long> createWriteKeysQueue(org.apache.hadoop.conf.Configuration conf)

Overrides:

createWriteKeysQueue in class MultiThreadedWriterBase