Package org.apache.hadoop.hbase.backup

Class TestBackupRestoreWithModifications

java.lang.Object

org.apache.hadoop.hbase.backup.TestBackupRestoreWithModifications

@Tag("org.apache.hadoop.hbase.testclassification.LargeTests")
public class TestBackupRestoreWithModifications
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
TestBackupRestoreWithModifications(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)
static Stream<org.junit.jupiter.params.provider.Arguments>	parameters()
private void	putLoad(org.apache.hadoop.hbase.TableName tableName, Instant timestamp, String data)
private void	restore(String backupId, org.apache.hadoop.hbase.TableName sourceTableName, org.apache.hadoop.hbase.TableName targetTableName)
void	setUp()
void	testModificationsOnTable()
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

TestBackupRestoreWithModifications

public TestBackupRestoreWithModifications(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

testModificationsOnTable

@TestTemplate
public void testModificationsOnTable()
                              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

restore

private void restore(String backupId,
 org.apache.hadoop.hbase.TableName sourceTableName,
 org.apache.hadoop.hbase.TableName targetTableName)
              throws IOException

Throws:

IOException

validateDataEquals

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

Throws:

IOException