org.apache.hadoop.hbase.snapshot

Class TestRestoreFlushSnapshotFromClient

java.lang.Object

org.apache.hadoop.hbase.snapshot.TestRestoreFlushSnapshotFromClient

Direct Known Subclasses:

TestMobRestoreFlushSnapshotFromClient

public class TestRestoreFlushSnapshotFromClient
extends Object

Test clone/restore snapshots from the client TODO This is essentially a clone of TestRestoreSnapshotFromClient. This is worth refactoring this because there will be a few more flavors of snapshots that need to run these tests.

Field Summary

Fields

Modifier and Type	Field and Description
protected org.apache.hadoop.hbase.client.Admin	admin
static HBaseClassTestRule	CLASS_RULE
protected byte[]	FAMILY
private static org.slf4j.Logger	LOG
protected int	snapshot0Rows
protected int	snapshot1Rows
protected byte[]	snapshotName0
protected byte[]	snapshotName1
protected byte[]	snapshotName2
protected org.apache.hadoop.hbase.TableName	tableName
protected static HBaseTestingUtility	UTIL

Constructor Summary

Constructors

Constructor and Description
TestRestoreFlushSnapshotFromClient()

Method Summary

Modifier and Type	Method and Description
protected int	countRows(org.apache.hadoop.hbase.client.Table table, byte[]... families)
protected void	createTable()
private void	logFSTree()
void	setup() Initialize the tests with a table filled with some data and two snapshots (snapshotName0, snapshotName1) of different states.
static void	setupCluster()
protected static void	setupConf(org.apache.hadoop.conf.Configuration conf)
void	tearDown()
static void	tearDownAfterClass()
void	testCloneNonExistentSnapshot()
void	testCloneSnapshot()
private void	testCloneSnapshot(org.apache.hadoop.hbase.TableName tableName, byte[] snapshotName, int snapshotRows)
void	testRestoreSnapshot()
void	testRestoreSnapshotOfCloned()
void	testTakeFlushSnapshot()
protected void	verifyRowCount(HBaseTestingUtility util, org.apache.hadoop.hbase.TableName tableName, long expectedRows)

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

UTIL

protected static final HBaseTestingUtility UTIL

FAMILY

protected final byte[] FAMILY

snapshotName0

protected byte[] snapshotName0

snapshotName1

protected byte[] snapshotName1

snapshotName2

protected byte[] snapshotName2

snapshot0Rows

protected int snapshot0Rows

snapshot1Rows

protected int snapshot1Rows

tableName

protected org.apache.hadoop.hbase.TableName tableName

admin

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

Constructor Detail

TestRestoreFlushSnapshotFromClient

public TestRestoreFlushSnapshotFromClient()

Method Detail

setupCluster

public static void setupCluster()
                         throws Exception

Throws:

Exception

setupConf

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

tearDownAfterClass

public static void tearDownAfterClass()
                               throws Exception

Throws:

Exception

createTable

protected void createTable()
                    throws Exception

Throws:

Exception

setup

public void setup()
           throws Exception

Initialize the tests with a table filled with some data and two snapshots (snapshotName0, snapshotName1) of different states. The tableName, snapshotNames and the number of rows in the snapshot are initialized.

Throws:

Exception

tearDown

public void tearDown()
              throws Exception

Throws:

Exception

testTakeFlushSnapshot

public void testTakeFlushSnapshot()
                           throws IOException

Throws:

IOException

testRestoreSnapshot

public void testRestoreSnapshot()
                         throws IOException

Throws:

IOException

testCloneNonExistentSnapshot

public void testCloneNonExistentSnapshot()
                                  throws IOException,
                                         InterruptedException

Throws:

IOException

InterruptedException

testCloneSnapshot

public void testCloneSnapshot()
                       throws IOException,
                              InterruptedException

Throws:

IOException

InterruptedException

testCloneSnapshot

private void testCloneSnapshot(org.apache.hadoop.hbase.TableName tableName,
                               byte[] snapshotName,
                               int snapshotRows)
                        throws IOException,
                               InterruptedException

Throws:

IOException

InterruptedException

testRestoreSnapshotOfCloned

public void testRestoreSnapshotOfCloned()
                                 throws IOException,
                                        InterruptedException

Throws:

IOException

InterruptedException

logFSTree

private void logFSTree()
                throws IOException

Throws:

IOException

verifyRowCount

protected void verifyRowCount(HBaseTestingUtility util,
                              org.apache.hadoop.hbase.TableName tableName,
                              long expectedRows)
                       throws IOException

Throws:

IOException

countRows

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

Throws:

IOException