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 and Description
private static class	TestBulkloadBase.WalMatcher

Field Summary

Fields

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

Constructor Summary

Constructors

Constructor and Description
TestBulkloadBase(boolean useFileBasedSFT)

Method Summary

Modifier and Type	Method and 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 Detail

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 Detail

TestBulkloadBase

public TestBulkloadBase(boolean useFileBasedSFT)

Method Detail

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)