org.apache.hadoop.hbase.snapshot

Class TestFlushSnapshotFromClient

java.lang.Object

org.apache.hadoop.hbase.snapshot.TestFlushSnapshotFromClient

public class TestFlushSnapshotFromClient
extends java.lang.Object

Test creating/using/deleting snapshots from the client

This is an end-to-end test for the snapshot utility TODO This is essentially a clone of TestSnapshotFromClient. 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 int	DEFAULT_NUM_ROWS
protected static int	NUM_RS
protected static TableName	TABLE_NAME
protected static byte[]	TEST_FAM
protected static HBaseTestingUtility	UTIL

Constructor Summary

Constructors

Constructor and Description
TestFlushSnapshotFromClient()

Method Summary

Modifier and Type	Method and Description
static void	cleanupTest()
protected int	countRows(Table table, byte[]... families)
protected void	createTable()
void	setup()
static void	setupCluster()
protected static void	setupConf(Configuration conf)
void	tearDown()
void	testAsyncFlushSnapshot()
void	testConcurrentSnapshottingAttempts() Demonstrate that we reject snapshot requests if there is a snapshot already running on the same table currently running and that concurrent snapshots on different tables can both succeed concurretly.
void	testFlushCreateListDestroy() Basic end-to-end test of simple-flush-based snapshots
void	testFlushTableSnapshot() Test simple flush snapshotting a table that is online
void	testFlushTableSnapshotWithProcedure() Test simple flush snapshotting a table that is online
void	testSkipFlushTableSnapshot() Test snapshotting a table that is online without flushing
void	testSnapshotFailsOnNonExistantTable()
void	testSnapshotStateAfterMerge()
void	testTakeSnapshotAfterMerge()
protected void	verifyRowCount(HBaseTestingUtility util, TableName tableName, long expectedRows)

Methods inherited from class java.lang.Object

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

Field Detail

UTIL

protected static final HBaseTestingUtility UTIL

NUM_RS

protected static final int NUM_RS

See Also:

Constant Field Values

TEST_FAM

protected static final byte[] TEST_FAM

TABLE_NAME

protected static final TableName TABLE_NAME

DEFAULT_NUM_ROWS

protected final int DEFAULT_NUM_ROWS

See Also:

Constant Field Values

Constructor Detail

TestFlushSnapshotFromClient

public TestFlushSnapshotFromClient()

Method Detail

setupCluster

public static void setupCluster()
                         throws java.lang.Exception

Throws:

java.lang.Exception

setupConf

protected static void setupConf(Configuration conf)

setup

public void setup()
           throws java.lang.Exception

Throws:

java.lang.Exception

createTable

protected void createTable()
                    throws java.lang.Exception

Throws:

java.lang.Exception

tearDown

public void tearDown()
              throws java.lang.Exception

Throws:

java.lang.Exception

cleanupTest

public static void cleanupTest()
                        throws java.lang.Exception

Throws:

java.lang.Exception

testFlushTableSnapshot

public void testFlushTableSnapshot()
                            throws java.lang.Exception

Test simple flush snapshotting a table that is online

Throws:

java.lang.Exception

testSkipFlushTableSnapshot

public void testSkipFlushTableSnapshot()
                                throws java.lang.Exception

Test snapshotting a table that is online without flushing

Throws:

java.lang.Exception

testFlushTableSnapshotWithProcedure

public void testFlushTableSnapshotWithProcedure()
                                         throws java.lang.Exception

Test simple flush snapshotting a table that is online

Throws:

java.lang.Exception

testSnapshotFailsOnNonExistantTable

public void testSnapshotFailsOnNonExistantTable()
                                         throws java.lang.Exception

Throws:

java.lang.Exception

testAsyncFlushSnapshot

public void testAsyncFlushSnapshot()
                            throws java.lang.Exception

Throws:

java.lang.Exception

testSnapshotStateAfterMerge

public void testSnapshotStateAfterMerge()
                                 throws java.lang.Exception

Throws:

java.lang.Exception

testTakeSnapshotAfterMerge

public void testTakeSnapshotAfterMerge()
                                throws java.lang.Exception

Throws:

java.lang.Exception

testFlushCreateListDestroy

public void testFlushCreateListDestroy()
                                throws java.lang.Exception

Basic end-to-end test of simple-flush-based snapshots

Throws:

java.lang.Exception

testConcurrentSnapshottingAttempts

public void testConcurrentSnapshottingAttempts()
                                        throws java.io.IOException,
                                               java.lang.InterruptedException

Demonstrate that we reject snapshot requests if there is a snapshot already running on the same table currently running and that concurrent snapshots on different tables can both succeed concurretly.

Throws:

java.io.IOException

java.lang.InterruptedException

verifyRowCount

protected void verifyRowCount(HBaseTestingUtility util,
                              TableName tableName,
                              long expectedRows)
                       throws java.io.IOException

Throws:

java.io.IOException

countRows

protected int countRows(Table table,
                        byte[]... families)
                 throws java.io.IOException

Throws:

java.io.IOException