Package org.apache.hadoop.hbase.regionserver

Class TestBulkloadBase

java.lang.Object

org.apache.hadoop.hbase.regionserver.TestBulkloadBase

Direct Known Subclasses:

TestBulkLoad, TestCompactionAfterBulkLoad

public class TestBulkloadBase
extends Object

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
private static class	TestBulkloadBase.WalMatcher

Field Summary

Fields

Modifier and Type	Field	Description
protected final org.apache.hadoop.conf.Configuration	conf
protected final byte[]	family1
protected final byte[]	family2
protected final byte[]	family3
protected final org.apache.hadoop.hbase.wal.WAL	log
org.junit.rules.TestName	name
private final byte[]	randomBytes
private static HBaseTestingUtility	TEST_UTIL
static org.junit.rules.TemporaryFolder	testFolder
protected Boolean	useFileBasedSFT

Constructor Summary

Constructors

Constructor	Description
TestBulkloadBase(boolean useFileBasedSFT)

Method Summary

Modifier and Type	Method	Description
void	before()
protected static org.hamcrest.Matcher<org.apache.hadoop.hbase.wal.WALEdit>	bulkLogWalEdit(byte[] typeBytes, byte[] tableName, byte[] familyName, List<String> storeFileNames)
protected static org.hamcrest.Matcher<org.apache.hadoop.hbase.wal.WALEdit>	bulkLogWalEditType(byte[] typeBytes)
private String	createHFileForFamilies(byte[] family)
static Collection<Boolean>	data()
private static String	generateUniqueName(String suffix)
private List<org.apache.hadoop.hbase.util.Pair<byte[],String>>	getBlankFamilyPaths()
private String	getNotExistFilePath()
protected org.apache.hadoop.hbase.regionserver.HRegion	testRegionWithFamilies(byte[]... families)
protected org.apache.hadoop.hbase.regionserver.HRegion	testRegionWithFamiliesAndSpecifiedTableName(org.apache.hadoop.hbase.TableName tableName, byte[]... families)
protected List<org.apache.hadoop.hbase.util.Pair<byte[],String>>	withFamilyPathsFor(byte[]... families)
protected org.apache.hadoop.hbase.util.Pair<byte[],String>	withInvalidColumnFamilyButProperHFileLocation(byte[] family)
protected org.apache.hadoop.hbase.util.Pair<byte[],String>	withMissingHFileForFamily(byte[] family)

Methods inherited from class java.lang.Object

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

Field Details

testFolder

public static org.junit.rules.TemporaryFolder testFolder

TEST_UTIL

private static HBaseTestingUtility TEST_UTIL

log

protected final org.apache.hadoop.hbase.wal.WAL log

conf

protected final org.apache.hadoop.conf.Configuration conf

randomBytes

private final byte[] randomBytes

family1

protected final byte[] family1

family2

protected final byte[] family2

family3

protected final byte[] family3

useFileBasedSFT

protected Boolean useFileBasedSFT

name

public org.junit.rules.TestName name

Constructor Details

TestBulkloadBase

public TestBulkloadBase(boolean useFileBasedSFT)

Method Details

data

public static Collection<Boolean> data()

before

public void before()
            throws IOException

Throws:

IOException

withMissingHFileForFamily

protected org.apache.hadoop.hbase.util.Pair<byte[],String> withMissingHFileForFamily(byte[] family)

getNotExistFilePath

private String getNotExistFilePath()

withInvalidColumnFamilyButProperHFileLocation

protected org.apache.hadoop.hbase.util.Pair<byte[],String> withInvalidColumnFamilyButProperHFileLocation(byte[] family)
                                                                                                  throws IOException

Throws:

IOException

testRegionWithFamiliesAndSpecifiedTableName

protected org.apache.hadoop.hbase.regionserver.HRegion testRegionWithFamiliesAndSpecifiedTableName(org.apache.hadoop.hbase.TableName tableName,
 byte[]... families)
                                                                                            throws IOException

Throws:

IOException

testRegionWithFamilies

protected org.apache.hadoop.hbase.regionserver.HRegion testRegionWithFamilies(byte[]... families)
                                                                       throws IOException

Throws:

IOException

getBlankFamilyPaths

private List<org.apache.hadoop.hbase.util.Pair<byte[],String>> getBlankFamilyPaths()

withFamilyPathsFor

protected List<org.apache.hadoop.hbase.util.Pair<byte[],String>> withFamilyPathsFor(byte[]... families)
                                                                             throws IOException

Throws:

IOException

createHFileForFamilies

private String createHFileForFamilies(byte[] family)
                               throws IOException

Throws:

IOException

generateUniqueName

private static String generateUniqueName(String suffix)

bulkLogWalEditType

protected static org.hamcrest.Matcher<org.apache.hadoop.hbase.wal.WALEdit> bulkLogWalEditType(byte[] typeBytes)

bulkLogWalEdit

protected static org.hamcrest.Matcher<org.apache.hadoop.hbase.wal.WALEdit> bulkLogWalEdit(byte[] typeBytes,
 byte[] tableName,
 byte[] familyName,
 List<String> storeFileNames)