Package org.apache.hadoop.hbase.util
Class TestMiniClusterLoadSequential
java.lang.Object
org.apache.hadoop.hbase.util.TestMiniClusterLoadSequential
- Direct Known Subclasses:
TestLoadAndSwitchEncodeOnDisk,TestMiniClusterLoadParallel
A write/read/verify load test on a mini HBase cluster. Tests reading and then writing.
-
Field Summary
FieldsModifier and TypeFieldDescriptionprotected static final byte[]static final HBaseClassTestRuleprotected org.apache.hadoop.hbase.io.compress.Compression.Algorithmprotected final org.apache.hadoop.conf.Configurationprotected final org.apache.hadoop.hbase.io.encoding.DataBlockEncodingprotected final booleanprivate static final org.slf4j.Loggerprotected static final intprotected static final intprotected intprotected org.apache.hadoop.hbase.util.MultiThreadedReaderprotected static final org.apache.hadoop.hbase.TableNameprotected static final HBaseTestingUtilprotected static final intprotected org.apache.hadoop.hbase.util.MultiThreadedWriter -
Constructor Summary
ConstructorsConstructorDescriptionTestMiniClusterLoadSequential(boolean isMultiPut, org.apache.hadoop.hbase.io.encoding.DataBlockEncoding dataBlockEncoding) -
Method Summary
Modifier and TypeMethodDescriptionprotected voidcreatePreSplitLoadTestTable(org.apache.hadoop.hbase.client.TableDescriptor tableDescriptor, org.apache.hadoop.hbase.client.ColumnFamilyDescriptor familyDescriptor) protected org.apache.hadoop.hbase.client.ColumnFamilyDescriptorgetColumnDesc(org.apache.hadoop.hbase.client.Admin admin) voidloadTest()protected intnumKeys()static Collection<Object[]>protected voidprotected org.apache.hadoop.hbase.util.MultiThreadedReaderprepareReaderThreads(org.apache.hadoop.hbase.util.test.LoadTestDataGenerator dataGen, org.apache.hadoop.conf.Configuration conf, org.apache.hadoop.hbase.TableName tableName, double verifyPercent) protected org.apache.hadoop.hbase.util.MultiThreadedWriterprepareWriterThreads(org.apache.hadoop.hbase.util.test.LoadTestDataGenerator dataGen, org.apache.hadoop.conf.Configuration conf, org.apache.hadoop.hbase.TableName tableName) protected voidvoidsetUp()voidtearDown()
-
Field Details
-
CLASS_RULE
-
LOG
-
TABLE
-
CF
-
NUM_THREADS
- See Also:
-
NUM_RS
- See Also:
-
TIMEOUT_MS
- See Also:
-
TEST_UTIL
-
conf
-
isMultiPut
-
dataBlockEncoding
-
writerThreads
-
readerThreads
-
numKeys
-
compression
-
-
Constructor Details
-
TestMiniClusterLoadSequential
public TestMiniClusterLoadSequential(boolean isMultiPut, org.apache.hadoop.hbase.io.encoding.DataBlockEncoding dataBlockEncoding)
-
-
Method Details
-
parameters
-
setUp
- Throws:
Exception
-
tearDown
- Throws:
Exception
-
prepareReaderThreads
protected org.apache.hadoop.hbase.util.MultiThreadedReader prepareReaderThreads(org.apache.hadoop.hbase.util.test.LoadTestDataGenerator dataGen, org.apache.hadoop.conf.Configuration conf, org.apache.hadoop.hbase.TableName tableName, double verifyPercent) throws IOException - Throws:
IOException
-
prepareWriterThreads
protected org.apache.hadoop.hbase.util.MultiThreadedWriter prepareWriterThreads(org.apache.hadoop.hbase.util.test.LoadTestDataGenerator dataGen, org.apache.hadoop.conf.Configuration conf, org.apache.hadoop.hbase.TableName tableName) throws IOException - Throws:
IOException
-
loadTest
- Throws:
Exception
-
runLoadTestOnExistingTable
- Throws:
IOException
-
createPreSplitLoadTestTable
protected void createPreSplitLoadTestTable(org.apache.hadoop.hbase.client.TableDescriptor tableDescriptor, org.apache.hadoop.hbase.client.ColumnFamilyDescriptor familyDescriptor) throws IOException - Throws:
IOException
-
prepareForLoadTest
- Throws:
IOException
-
numKeys
-
getColumnDesc
protected org.apache.hadoop.hbase.client.ColumnFamilyDescriptor getColumnDesc(org.apache.hadoop.hbase.client.Admin admin) throws org.apache.hadoop.hbase.TableNotFoundException, IOException - Throws:
org.apache.hadoop.hbase.TableNotFoundExceptionIOException
-