Package org.apache.hadoop.hbase.backup

Class TestIncrementalBackupMergeWithBulkLoad

java.lang.Object

org.apache.hadoop.hbase.backup.TestIncrementalBackupMergeWithBulkLoad

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
static final HBaseClassTestRule	CLASS_RULE
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()

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)
static Iterable<Object[]>	data()
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)
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

CLASS_RULE

public static final HBaseClassTestRule CLASS_RULE

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

Method Details

data

public static Iterable<Object[]> data()

beforeClass

public static void beforeClass()
                        throws Exception

Throws:

Exception

afterClass

public static void afterClass()
                       throws Exception

Throws:

Exception

setUp

public void setUp()
           throws Exception

Throws:

Exception

testMergeContainingBulkloadedHfiles

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