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
Modifier and TypeFieldDescriptionprotected static final byte[]
static final HBaseClassTestRule
protected org.apache.hadoop.hbase.io.compress.Compression.Algorithm
protected final org.apache.hadoop.conf.Configuration
protected final org.apache.hadoop.hbase.io.encoding.DataBlockEncoding
protected final boolean
private static final org.slf4j.Logger
protected static final int
protected static final int
protected int
protected org.apache.hadoop.hbase.util.MultiThreadedReader
protected static final org.apache.hadoop.hbase.TableName
protected static final HBaseTestingUtil
protected static final int
protected org.apache.hadoop.hbase.util.MultiThreadedWriter
-
Constructor Summary
ConstructorDescriptionTestMiniClusterLoadSequential
(boolean isMultiPut, org.apache.hadoop.hbase.io.encoding.DataBlockEncoding dataBlockEncoding) -
Method Summary
Modifier and TypeMethodDescriptionprotected void
createPreSplitLoadTestTable
(org.apache.hadoop.hbase.client.TableDescriptor tableDescriptor, org.apache.hadoop.hbase.client.ColumnFamilyDescriptor familyDescriptor) protected org.apache.hadoop.hbase.client.ColumnFamilyDescriptor
getColumnDesc
(org.apache.hadoop.hbase.client.Admin admin) void
loadTest()
protected int
numKeys()
static Collection<Object[]>
protected void
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) 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) protected void
void
setUp()
void
tearDown()
-
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.TableNotFoundException
IOException
-