Package org.apache.hadoop.hbase.backup

Class TestIncrementalBackupWithContinuous

java.lang.Object

org.apache.hadoop.hbase.backup.TestBackupBase

org.apache.hadoop.hbase.backup.TestIncrementalBackupWithContinuous

@Tag("org.apache.hadoop.hbase.testclassification.LargeTests")
public class TestIncrementalBackupWithContinuous
extends TestBackupBase

Nested Class Summary

Nested classes/interfaces inherited from class org.apache.hadoop.hbase.backup.TestBackupBase

TestBackupBase.FullTableBackupClientForTest, TestBackupBase.IncrementalTableBackupClientForTest

Field Summary

Fields

Modifier and Type	Field	Description
private static final String	backupWalDirName
private org.apache.hadoop.fs.FileSystem	fs
private static final org.slf4j.Logger	LOG
private static final int	ROWS_IN_BULK_LOAD

Fields inherited from class org.apache.hadoop.hbase.backup.TestBackupBase

autoRestoreOnFailure, BACKUP_REMOTE_ROOT_DIR, BACKUP_ROOT_DIR, conf1, conf2, famName, NB_ROWS_IN_BATCH, provider, qualName, secure, table1, table1_restore, table1Desc, table2, table2_restore, table3, table3_restore, table4, TEST_UTIL, TEST_UTIL2, useSecondCluster

Constructor Summary

Constructors

Constructor	Description
TestIncrementalBackupWithContinuous()

Method Summary

Modifier and Type	Method	Description
void	afterTest()
void	beforeTest()
private static Set<String>	listFiles(org.apache.hadoop.fs.FileSystem fs, org.apache.hadoop.fs.Path root, org.apache.hadoop.fs.Path dir)
protected static void	loadTable(org.apache.hadoop.hbase.client.Table table)
protected static void	loadTables(List<org.apache.hadoop.hbase.client.Table> tables)
private void	performBulkLoad(String keyPrefix, String testDir, org.apache.hadoop.hbase.TableName tableName)
void	testContinuousBackupWithIncrementalBackupSuccess()
void	testIncrementalBackupCopyingBulkloadTillIncrCommittedWalTs()
void	testMultiTableContinuousBackupWithIncrementalBackupSuccess()
private void	verifyRestoredTableDataIntegrity(org.apache.hadoop.hbase.TableName restoredTableName, String originalTableChecksum, int expectedRowCount)

Methods inherited from class org.apache.hadoop.hbase.backup.TestBackupBase

backupTables, backupTables, checkFailed, checkSucceeded, createBackupRequest, createBackupRequest, createBackupRequest, createTables, deleteContinuousBackupReplicationPeerIfExists, dumpBackupDir, fullTableBackup, getBackupAdmin, getLatestBackupManifest, getListOfWALFiles, incrementalTableBackup, insertIntoTable, setUp, setUpHelper, tearDown, toList

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

ROWS_IN_BULK_LOAD

private static final int ROWS_IN_BULK_LOAD

See Also:

• Constant Field Values

backupWalDirName

private static final String backupWalDirName

See Also:

• Constant Field Values

fs

private org.apache.hadoop.fs.FileSystem fs

Constructor Details

TestIncrementalBackupWithContinuous

public TestIncrementalBackupWithContinuous()

Method Details

beforeTest

@BeforeEach
public void beforeTest()
                throws IOException

Throws:

IOException

afterTest

@AfterEach
public void afterTest()
               throws IOException

Throws:

IOException

testContinuousBackupWithIncrementalBackupSuccess

@Test
public void testContinuousBackupWithIncrementalBackupSuccess()
                                                      throws Exception

Throws:

Exception

testMultiTableContinuousBackupWithIncrementalBackupSuccess

@Test
public void testMultiTableContinuousBackupWithIncrementalBackupSuccess()
                                                                throws Exception

Throws:

Exception

testIncrementalBackupCopyingBulkloadTillIncrCommittedWalTs

@Test
public void testIncrementalBackupCopyingBulkloadTillIncrCommittedWalTs()
                                                                throws Exception

Throws:

Exception

performBulkLoad

private void performBulkLoad(String keyPrefix,
 String testDir,
 org.apache.hadoop.hbase.TableName tableName)
                      throws IOException

Throws:

IOException

listFiles

private static Set<String> listFiles(org.apache.hadoop.fs.FileSystem fs,
 org.apache.hadoop.fs.Path root,
 org.apache.hadoop.fs.Path dir)
                              throws IOException

Throws:

IOException

loadTable

protected static void loadTable(org.apache.hadoop.hbase.client.Table table)
                         throws Exception

Throws:

Exception

loadTables

protected static void loadTables(List<org.apache.hadoop.hbase.client.Table> tables)
                          throws Exception

Throws:

Exception

verifyRestoredTableDataIntegrity

private void verifyRestoredTableDataIntegrity(org.apache.hadoop.hbase.TableName restoredTableName,
 String originalTableChecksum,
 int expectedRowCount)
                                       throws Exception

Throws:

Exception