Package org.apache.hadoop.hbase.backup

Class TestIncrementalBackupMergeWithBulkLoad

java.lang.Object

org.apache.hadoop.hbase.backup.TestIncrementalBackupMergeWithBulkLoad

@Tag("org.apache.hadoop.hbase.testclassification.LargeTests")
public class TestIncrementalBackupMergeWithBulkLoad
extends Object

Field Summary

Fields

Modifier and Type	Field	Description
private List<org.apache.hadoop.hbase.TableName>	allTables
private static final org.apache.hadoop.fs.Path	BACKUP_ROOT_DIR
private static org.apache.hadoop.hbase.testing.TestingHBaseCluster	cluster
private static final byte[]	COLUMN_FAMILY
private static final org.slf4j.Logger	LOG
private org.apache.hadoop.hbase.TableName	sourceTable
private org.apache.hadoop.hbase.TableName	targetTable
boolean	useBulkLoad

Constructor Summary

Constructors

Constructor	Description
TestIncrementalBackupMergeWithBulkLoad(boolean useBulkLoad)

Method Summary

Modifier and Type	Method	Description
static void	afterClass()
private String	backup(org.apache.hadoop.hbase.backup.BackupType backupType, List<org.apache.hadoop.hbase.TableName> tables)
static void	beforeClass()
private void	createTable(org.apache.hadoop.hbase.TableName tableName)
private void	hFileBulkLoad(org.apache.hadoop.hbase.TableName tableName, Instant timestamp, String data)
private void	load(org.apache.hadoop.hbase.TableName tableName, Instant timestamp, String data)
private void	merge(String[] backupIds)
static Stream<org.junit.jupiter.params.provider.Arguments>	parameters()
private void	putLoad(org.apache.hadoop.hbase.TableName tableName, Instant timestamp, String data)
void	setUp()
void	testMergeContainingBulkloadedHfiles()
private void	validateDataEquals(org.apache.hadoop.hbase.TableName tableName, String expectedData)

Methods inherited from class java.lang.Object

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

Field Details

LOG

private static final org.slf4j.Logger LOG

useBulkLoad

public boolean useBulkLoad

sourceTable

private org.apache.hadoop.hbase.TableName sourceTable

targetTable

private org.apache.hadoop.hbase.TableName targetTable

allTables

private List<org.apache.hadoop.hbase.TableName> allTables

cluster

private static org.apache.hadoop.hbase.testing.TestingHBaseCluster cluster

BACKUP_ROOT_DIR

private static final org.apache.hadoop.fs.Path BACKUP_ROOT_DIR

COLUMN_FAMILY

private static final byte[] COLUMN_FAMILY

Constructor Details

TestIncrementalBackupMergeWithBulkLoad

public TestIncrementalBackupMergeWithBulkLoad(boolean useBulkLoad)

Method Details

parameters

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

beforeClass

@BeforeAll
public static void beforeClass()
                        throws Exception

Throws:

Exception

afterClass

@AfterAll
public static void afterClass()
                       throws Exception

Throws:

Exception

setUp

@BeforeEach
public void setUp()
           throws Exception

Throws:

Exception

testMergeContainingBulkloadedHfiles

@TestTemplate
public void testMergeContainingBulkloadedHfiles()
                                         throws Exception

Throws:

Exception

createTable

private void createTable(org.apache.hadoop.hbase.TableName tableName)
                  throws IOException

Throws:

IOException

load

private void load(org.apache.hadoop.hbase.TableName tableName,
 Instant timestamp,
 String data)
           throws IOException

Throws:

IOException

putLoad

private void putLoad(org.apache.hadoop.hbase.TableName tableName,
 Instant timestamp,
 String data)
              throws IOException

Throws:

IOException

hFileBulkLoad

private void hFileBulkLoad(org.apache.hadoop.hbase.TableName tableName,
 Instant timestamp,
 String data)
                    throws IOException

Throws:

IOException

backup

private String backup(org.apache.hadoop.hbase.backup.BackupType backupType,
 List<org.apache.hadoop.hbase.TableName> tables)
               throws IOException

Throws:

IOException

merge

private void merge(String[] backupIds)
            throws IOException

Throws:

IOException

validateDataEquals

private void validateDataEquals(org.apache.hadoop.hbase.TableName tableName,
 String expectedData)
                         throws IOException

Throws:

IOException