public static class IntegrationTestRegionReplicaReplication.DelayingMultiThreadedWriter
extends MultiThreadedWriter
Constructor and Description |
---|
DelayingMultiThreadedWriter(LoadTestDataGenerator dataGen,
Configuration conf,
TableName tableName) |
Modifier and Type | Method and Description |
---|---|
protected java.util.concurrent.BlockingQueue<java.lang.Long> |
createWriteKeysQueue(Configuration conf) |
public DelayingMultiThreadedWriter(LoadTestDataGenerator dataGen, Configuration conf, TableName tableName) throws java.io.IOException
java.io.IOException