org.apache.hadoop.hbase

Class IntegrationTestRegionReplicaReplication.DelayingMultiThreadedWriter

java.lang.Object

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.

Constructor Summary

Constructors

Constructor and Description
DelayingMultiThreadedWriter(LoadTestDataGenerator dataGen, Configuration conf, TableName tableName)

Method Summary

Modifier and Type	Method and Description
protected BlockingQueue<Long>	createWriteKeysQueue(Configuration conf)

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

DelayingMultiThreadedWriter

public DelayingMultiThreadedWriter(LoadTestDataGenerator dataGen,
                                   Configuration conf,
                                   TableName tableName)
                            throws IOException

Throws:

IOException

Method Detail

createWriteKeysQueue

protected BlockingQueue<Long> createWriteKeysQueue(Configuration conf)