org.apache.hadoop.hbase.client

Class TestSnapshotCloneIndependence

java.lang.Object

org.apache.hadoop.hbase.client.TestSnapshotCloneIndependence

Direct Known Subclasses:

TestMobSnapshotCloneIndependence

public class TestSnapshotCloneIndependence
extends Object

Test to verify that the cloned table is independent of the table from which it was cloned

Field Summary

Fields

Modifier and Type	Field and Description
private org.apache.hadoop.hbase.client.Admin	admin
static HBaseClassTestRule	CLASS_RULE
private static int	CLEANER_INTERVAL
private org.apache.hadoop.hbase.TableName	cloneTableName
private int	countOriginalTable
private org.apache.hadoop.fs.FileSystem	fs
private static org.slf4j.Logger	LOG
protected static int	NUM_RS
private org.apache.hadoop.hbase.client.Table	originalTable
private org.apache.hadoop.hbase.TableName	originalTableName
private org.apache.hadoop.fs.Path	rootDir
(package private) byte[]	snapshotName
(package private) String	snapshotNameAsString
private static String	STRING_TABLE_NAME
protected static byte[]	TEST_FAM
private static String	TEST_FAM_STR
org.junit.rules.TestName	testName
protected static HBaseTestingUtility	UTIL

Constructor Summary

Constructors

Constructor and Description
TestSnapshotCloneIndependence()

Method Summary

Modifier and Type	Method and Description
static void	cleanupTest()
protected int	countRows(org.apache.hadoop.hbase.client.Table table, byte[]... families)
private void	createAndCloneSnapshot(boolean online) Takes the snapshot of originalTable and clones the snapshot to another tables.
protected org.apache.hadoop.hbase.client.Table	createTable(org.apache.hadoop.hbase.TableName table, byte[] family)
void	loadData(org.apache.hadoop.hbase.client.Table table, byte[]... families)
private void	runTestRegionOperationsIndependent() Do a split, and verify that this only affects one table
private void	runTestSnapshotAppendIndependent() Verify that adding data to original table or clone table doesn't affect other table.
private void	runTestSnapshotDeleteIndependent() Verify that deleting the snapshot does not affect either table.
private void	runTestSnapshotMetadataChangesIndependent() Add metadata, and verify that this only affects one table
void	setup()
static void	setupCluster() Setup the config for the cluster and start it
(package private) static void	setupConf(org.apache.hadoop.conf.Configuration conf)
void	tearDown()
void	testOfflineSnapshotAppendIndependent() Verify that adding data to the cloned table will not affect the original, and vice-versa when it is taken as an offline snapshot.
void	testOfflineSnapshotDeleteIndependent()
void	testOfflineSnapshotMetadataChangesIndependent() Verify that adding netadata to the cloned table will not affect the original, and vice-versa when is taken as an online snapshot.
void	testOfflineSnapshotRegionOperationsIndependent() Verify that region operations, in this case splitting a region, are independent between the cloned table and the original.
void	testOnlineSnapshotAppendIndependent() Verify that adding data to the cloned table will not affect the original, and vice-versa when it is taken as an online snapshot.
void	testOnlineSnapshotDeleteIndependent()
void	testOnlineSnapshotMetadataChangesIndependent() Verify that adding metadata to the cloned table will not affect the original, and vice-versa when it is taken as an online snapshot.
void	testOnlineSnapshotRegionOperationsIndependent() Verify that region operations, in this case splitting a region, are independent between the cloned table and the original.
private static void	waitOnSplit(org.apache.hadoop.hbase.client.Connection c, org.apache.hadoop.hbase.client.Table t, int originalCount)

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Field Detail

CLASS_RULE

public static final HBaseClassTestRule CLASS_RULE

LOG

private static final org.slf4j.Logger LOG

testName

public org.junit.rules.TestName testName

UTIL

protected static final HBaseTestingUtility UTIL

NUM_RS

protected static final int NUM_RS

See Also:

Constant Field Values

STRING_TABLE_NAME

private static final String STRING_TABLE_NAME

See Also:

Constant Field Values

TEST_FAM_STR

private static final String TEST_FAM_STR

See Also:

Constant Field Values

TEST_FAM

protected static final byte[] TEST_FAM

CLEANER_INTERVAL

private static final int CLEANER_INTERVAL

See Also:

Constant Field Values

fs

private org.apache.hadoop.fs.FileSystem fs

rootDir

private org.apache.hadoop.fs.Path rootDir

admin

private org.apache.hadoop.hbase.client.Admin admin

originalTableName

private org.apache.hadoop.hbase.TableName originalTableName

originalTable

private org.apache.hadoop.hbase.client.Table originalTable

cloneTableName

private org.apache.hadoop.hbase.TableName cloneTableName

countOriginalTable

private int countOriginalTable

snapshotNameAsString

String snapshotNameAsString

snapshotName

byte[] snapshotName

Constructor Detail

TestSnapshotCloneIndependence

public TestSnapshotCloneIndependence()

Method Detail

setupCluster

public static void setupCluster()
                         throws Exception

Setup the config for the cluster and start it

Throws:

Exception

setupConf

static void setupConf(org.apache.hadoop.conf.Configuration conf)

setup

public void setup()
           throws Exception

Throws:

Exception

tearDown

public void tearDown()
              throws Exception

Throws:

Exception

cleanupTest

public static void cleanupTest()
                        throws Exception

Throws:

Exception

testOnlineSnapshotAppendIndependent

public void testOnlineSnapshotAppendIndependent()
                                         throws Exception

Verify that adding data to the cloned table will not affect the original, and vice-versa when it is taken as an online snapshot.

Throws:

Exception

testOfflineSnapshotAppendIndependent

public void testOfflineSnapshotAppendIndependent()
                                          throws Exception

Verify that adding data to the cloned table will not affect the original, and vice-versa when it is taken as an offline snapshot.

Throws:

Exception

testOnlineSnapshotMetadataChangesIndependent

public void testOnlineSnapshotMetadataChangesIndependent()
                                                  throws Exception

Verify that adding metadata to the cloned table will not affect the original, and vice-versa when it is taken as an online snapshot.

Throws:

Exception

testOfflineSnapshotMetadataChangesIndependent

public void testOfflineSnapshotMetadataChangesIndependent()
                                                   throws Exception

Verify that adding netadata to the cloned table will not affect the original, and vice-versa when is taken as an online snapshot.

Throws:

Exception

testOfflineSnapshotRegionOperationsIndependent

public void testOfflineSnapshotRegionOperationsIndependent()
                                                    throws Exception

Verify that region operations, in this case splitting a region, are independent between the cloned table and the original.

Throws:

Exception

testOnlineSnapshotRegionOperationsIndependent

public void testOnlineSnapshotRegionOperationsIndependent()
                                                   throws Exception

Verify that region operations, in this case splitting a region, are independent between the cloned table and the original.

Throws:

Exception

testOfflineSnapshotDeleteIndependent

public void testOfflineSnapshotDeleteIndependent()
                                          throws Exception

Throws:

Exception

testOnlineSnapshotDeleteIndependent

public void testOnlineSnapshotDeleteIndependent()
                                         throws Exception

Throws:

Exception

waitOnSplit

private static void waitOnSplit(org.apache.hadoop.hbase.client.Connection c,
                                org.apache.hadoop.hbase.client.Table t,
                                int originalCount)
                         throws Exception

Throws:

Exception

createAndCloneSnapshot

private void createAndCloneSnapshot(boolean online)
                             throws Exception

Takes the snapshot of originalTable and clones the snapshot to another tables. If online is false, the original table is disabled during taking snapshot, so also enables it again.

Parameters:

online - - Whether the table is online or not during the snapshot

Throws:

Exception

runTestSnapshotAppendIndependent

private void runTestSnapshotAppendIndependent()
                                       throws Exception

Verify that adding data to original table or clone table doesn't affect other table.

Throws:

Exception

runTestRegionOperationsIndependent

private void runTestRegionOperationsIndependent()
                                         throws Exception

Do a split, and verify that this only affects one table

Throws:

Exception

runTestSnapshotMetadataChangesIndependent

private void runTestSnapshotMetadataChangesIndependent()
                                                throws Exception

Add metadata, and verify that this only affects one table

Throws:

Exception

runTestSnapshotDeleteIndependent

private void runTestSnapshotDeleteIndependent()
                                       throws Exception

Verify that deleting the snapshot does not affect either table.

Throws:

Exception

createTable

protected org.apache.hadoop.hbase.client.Table createTable(org.apache.hadoop.hbase.TableName table,
                                                           byte[] family)
                                                    throws Exception

Throws:

Exception

loadData

public void loadData(org.apache.hadoop.hbase.client.Table table,
                     byte[]... families)
              throws Exception

Throws:

Exception

countRows

protected int countRows(org.apache.hadoop.hbase.client.Table table,
                        byte[]... families)
                 throws Exception

Throws:

Exception