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
private String	name
private final byte[]	randomBytes
private static HBaseTestingUtil	TEST_UTIL
static File	testFolder
protected Boolean	useFileBasedSFT

Constructor Summary

Constructors

Constructor	Description
TestBulkloadBase(boolean useFileBasedSFT)

Method Summary

Modifier and Type	Method	Description
void	before(org.junit.jupiter.api.TestInfo testInfo)
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)
protected static String	generateUniqueName(String suffix)
private List<org.apache.hadoop.hbase.util.Pair<byte[],String>>	getBlankFamilyPaths()
private String	getNotExistFilePath()
static Stream<org.junit.jupiter.params.provider.Arguments>	parameters()
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

@TempDir
public static File testFolder

TEST_UTIL

private static HBaseTestingUtil 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

private String name

Constructor Details

TestBulkloadBase

public TestBulkloadBase(boolean useFileBasedSFT)

Method Details

parameters

public static Stream<org.junit.jupiter.params.provider.Arguments> parameters()

before

@BeforeEach
public void before(org.junit.jupiter.api.TestInfo testInfo)
            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

protected 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)