Package org.apache.hadoop.hbase.backup

Class TestContinuousBackup

java.lang.Object

org.apache.hadoop.hbase.backup.TestBackupBase

org.apache.hadoop.hbase.backup.TestContinuousBackup

@Tag("org.apache.hadoop.hbase.testclassification.LargeTests")
public class TestContinuousBackup
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
(package private) String	backupWalDirName
private static final org.slf4j.Logger	LOG

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
TestContinuousBackup()

Method Summary

Modifier and Type	Method	Description
void	afterTest()
void	beforeTest()
(package private) String[]	buildBackupArgs(String backupType, org.apache.hadoop.hbase.TableName[] tables, boolean continuousEnabled)
void	testContinuousBackupForMultipleTables()
void	testContinuousBackupWithFullBackup()
void	testContinuousBackupWithIncrementalBackup()
void	testContinuousBackupWithWALDirNotSpecified()
void	testInvalidBackupScenarioWithContinuousEnabled()
private void	verifyReplicationPeerSubscription(org.apache.hadoop.hbase.TableName table)
private void	verifyTableInBackupSystemTable(org.apache.hadoop.hbase.TableName table)

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, loadTable, 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

backupWalDirName

String backupWalDirName

Constructor Details

TestContinuousBackup

public TestContinuousBackup()

Method Details

beforeTest

@BeforeEach
public void beforeTest()
                throws IOException

Throws:

IOException

afterTest

@AfterEach
public void afterTest()
               throws IOException

Throws:

IOException

testContinuousBackupWithFullBackup

@Test
public void testContinuousBackupWithFullBackup()
                                        throws Exception

Throws:

Exception

testContinuousBackupForMultipleTables

@Test
public void testContinuousBackupForMultipleTables()
                                           throws Exception

Throws:

Exception

testInvalidBackupScenarioWithContinuousEnabled

@Test
public void testInvalidBackupScenarioWithContinuousEnabled()
                                                    throws Exception

Throws:

Exception

testContinuousBackupWithWALDirNotSpecified

@Test
public void testContinuousBackupWithWALDirNotSpecified()
                                                throws Exception

Throws:

Exception

testContinuousBackupWithIncrementalBackup

@Test
public void testContinuousBackupWithIncrementalBackup()
                                               throws Exception

Throws:

Exception

verifyReplicationPeerSubscription

private void verifyReplicationPeerSubscription(org.apache.hadoop.hbase.TableName table)
                                        throws IOException

Throws:

IOException

buildBackupArgs

String[] buildBackupArgs(String backupType,
 org.apache.hadoop.hbase.TableName[] tables,
 boolean continuousEnabled)

verifyTableInBackupSystemTable

private void verifyTableInBackupSystemTable(org.apache.hadoop.hbase.TableName table)
                                     throws IOException

Throws:

IOException