org.apache.hadoop.hbase

Class IntegrationTestRegionReplicaReplication.DelayingMultiThreadedUpdater

java.lang.Object

org.apache.hadoop.hbase.util.MultiThreadedAction

org.apache.hadoop.hbase.util.MultiThreadedWriterBase

org.apache.hadoop.hbase.util.MultiThreadedUpdater

org.apache.hadoop.hbase.IntegrationTestRegionReplicaReplication.DelayingMultiThreadedUpdater

Enclosing class:

IntegrationTestRegionReplicaReplication

public static class IntegrationTestRegionReplicaReplication.DelayingMultiThreadedUpdater
extends MultiThreadedUpdater

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.MultiThreadedUpdater

MultiThreadedUpdater.HBaseUpdaterThread

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.MultiThreadedUpdater

updaters

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

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.MultiThreadedUpdater

addUpdaterThreads, linkToWriter, mutate, mutate, setBatchUpdate, setIgnoreNonceConflicts, 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

DelayingMultiThreadedUpdater

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

Throws:

IOException

Method Detail

createWriteKeysQueue

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

Overrides:

createWriteKeysQueue in class MultiThreadedWriterBase