public class TestMiniClusterLoadSequential
extends java.lang.Object
Modifier and Type | Field and Description |
---|---|
protected static byte[] |
CF |
protected Compression.Algorithm |
compression |
protected Configuration |
conf |
protected DataBlockEncoding |
dataBlockEncoding |
protected boolean |
isMultiPut |
protected static int |
NUM_RS |
protected static int |
NUM_THREADS |
protected int |
numKeys |
protected MultiThreadedReader |
readerThreads |
protected static TableName |
TABLE |
protected static HBaseTestingUtility |
TEST_UTIL |
protected static int |
TIMEOUT_MS |
protected MultiThreadedWriter |
writerThreads |
Constructor and Description |
---|
TestMiniClusterLoadSequential(boolean isMultiPut,
DataBlockEncoding dataBlockEncoding) |
Modifier and Type | Method and Description |
---|---|
protected void |
createPreSplitLoadTestTable(HTableDescriptor htd,
HColumnDescriptor hcd) |
protected HColumnDescriptor |
getColumnDesc(Admin admin) |
void |
loadTest() |
protected int |
numKeys() |
static java.util.Collection<java.lang.Object[]> |
parameters() |
protected void |
prepareForLoadTest() |
protected MultiThreadedReader |
prepareReaderThreads(LoadTestDataGenerator dataGen,
Configuration conf,
TableName tableName,
double verifyPercent) |
protected MultiThreadedWriter |
prepareWriterThreads(LoadTestDataGenerator dataGen,
Configuration conf,
TableName tableName) |
protected void |
runLoadTestOnExistingTable() |
void |
setUp() |
void |
tearDown() |
protected static final TableName TABLE
protected static final byte[] CF
protected static final int NUM_THREADS
protected static final int NUM_RS
protected static final int TIMEOUT_MS
protected static final HBaseTestingUtility TEST_UTIL
protected final Configuration conf
protected final boolean isMultiPut
protected final DataBlockEncoding dataBlockEncoding
protected MultiThreadedWriter writerThreads
protected MultiThreadedReader readerThreads
protected int numKeys
protected Compression.Algorithm compression
public TestMiniClusterLoadSequential(boolean isMultiPut, DataBlockEncoding dataBlockEncoding)
public static java.util.Collection<java.lang.Object[]> parameters()
public void setUp() throws java.lang.Exception
java.lang.Exception
public void tearDown() throws java.lang.Exception
java.lang.Exception
protected MultiThreadedReader prepareReaderThreads(LoadTestDataGenerator dataGen, Configuration conf, TableName tableName, double verifyPercent) throws java.io.IOException
java.io.IOException
protected MultiThreadedWriter prepareWriterThreads(LoadTestDataGenerator dataGen, Configuration conf, TableName tableName) throws java.io.IOException
java.io.IOException
public void loadTest() throws java.lang.Exception
java.lang.Exception
protected void runLoadTestOnExistingTable() throws java.io.IOException
java.io.IOException
protected void createPreSplitLoadTestTable(HTableDescriptor htd, HColumnDescriptor hcd) throws java.io.IOException
java.io.IOException
protected void prepareForLoadTest() throws java.io.IOException
java.io.IOException
protected int numKeys()
protected HColumnDescriptor getColumnDesc(Admin admin) throws TableNotFoundException, java.io.IOException
TableNotFoundException
java.io.IOException