Package org.apache.hadoop.hbase.backup

Class TestBackupRestoreOnEmptyEnvironment

java.lang.Object

org.apache.hadoop.hbase.backup.TestBackupRestoreOnEmptyEnvironment

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

Field Summary

Fields

Modifier and Type	Field	Description
private static 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
boolean	restoreToOtherTable
private org.apache.hadoop.hbase.TableName	sourceTable
private org.apache.hadoop.hbase.TableName	targetTable

Constructor Summary

Constructors

Constructor	Description
TestBackupRestoreOnEmptyEnvironment(boolean restoreToOtherTable)

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	deleteTables()
static Stream<org.junit.jupiter.params.provider.Arguments>	parameters()
private void	putLoad(org.apache.hadoop.hbase.TableName tableName, Instant timestamp, String data)
void	removeTables()
private void	restore(String backupId, org.apache.hadoop.hbase.TableName sourceTableName, org.apache.hadoop.hbase.TableName targetTableName)
void	setUp()
void	testRestoreCorrectTableForIncremental()
void	testRestoreToCorrectTable()
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

restoreToOtherTable

public boolean restoreToOtherTable

sourceTable

private org.apache.hadoop.hbase.TableName sourceTable

targetTable

private org.apache.hadoop.hbase.TableName targetTable

cluster

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

BACKUP_ROOT_DIR

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

COLUMN_FAMILY

private static final byte[] COLUMN_FAMILY

Constructor Details

TestBackupRestoreOnEmptyEnvironment

public TestBackupRestoreOnEmptyEnvironment(boolean restoreToOtherTable)

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

removeTables

@AfterEach
public void removeTables()
                  throws Exception

Throws:

Exception

testRestoreToCorrectTable

@TestTemplate
public void testRestoreToCorrectTable()
                               throws Exception

Throws:

Exception

testRestoreCorrectTableForIncremental

@TestTemplate
public void testRestoreCorrectTableForIncremental()
                                           throws Exception

Throws:

Exception

createTable

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

Throws:

IOException

deleteTables

private void deleteTables()
                   throws IOException

Throws:

IOException

putLoad

private void putLoad(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