Package org.apache.hadoop.hbase.snapshot

Class TestFlushSnapshotFromClient

java.lang.Object

org.apache.hadoop.hbase.snapshot.TestFlushSnapshotFromClient

Direct Known Subclasses:

TestConcurrentFlushSnapshotFromClient, TestMobFlushSnapshotFromClient

public class TestFlushSnapshotFromClient
extends 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	Description
protected org.apache.hadoop.hbase.client.Admin	admin
static final HBaseClassTestRule	CLASS_RULE
protected final int	DEFAULT_NUM_ROWS
private static final org.slf4j.Logger	LOG
protected static final int	NUM_RS
protected static final org.apache.hadoop.hbase.TableName	TABLE_NAME
protected static final byte[]	TEST_FAM
protected static final HBaseTestingUtil	UTIL

Constructor Summary

Constructors

Constructor	Description
TestFlushSnapshotFromClient()

Method Summary

Modifier and Type	Method	Description
static void	cleanupTest()
protected int	countRows(org.apache.hadoop.hbase.client.Table table, byte[]... families)
protected void	createTable()
void	setup()
static void	setupCluster()
protected static void	setupConf(org.apache.hadoop.conf.Configuration conf)
void	tearDown()
void	testAsyncFlushSnapshot()
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(HBaseTestingUtil util, org.apache.hadoop.hbase.TableName tableName, long expectedRows)
private static void	waitForSnapshotToComplete(org.apache.hadoop.hbase.master.HMaster master, org.apache.hadoop.hbase.shaded.protobuf.generated.SnapshotProtos.SnapshotDescription snapshot, long timeoutNanos)	Helper method for testing async snapshot operations.
private void	waitRegionsAfterMerge(long numRegionsAfterMerge)

Methods inherited from class java.lang.Object

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

Field Details

CLASS_RULE

public static final HBaseClassTestRule CLASS_RULE

LOG

private static final org.slf4j.Logger LOG

UTIL

protected static final HBaseTestingUtil 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 org.apache.hadoop.hbase.TableName TABLE_NAME

DEFAULT_NUM_ROWS

protected final int DEFAULT_NUM_ROWS

See Also:

• Constant Field Values

admin

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

Constructor Details

TestFlushSnapshotFromClient

public TestFlushSnapshotFromClient()

Method Details

setupCluster

public static void setupCluster()
                         throws Exception

Throws:

Exception

setupConf

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

setup

public void setup()
           throws Exception

Throws:

Exception

createTable

protected void createTable()
                    throws Exception

Throws:

Exception

tearDown

public void tearDown()
              throws Exception

Throws:

Exception

cleanupTest

public static void cleanupTest()
                        throws Exception

Throws:

Exception

testFlushTableSnapshot

public void testFlushTableSnapshot()
                            throws Exception

Test simple flush snapshotting a table that is online

Throws:

Exception

testSkipFlushTableSnapshot

public void testSkipFlushTableSnapshot()
                                throws Exception

Test snapshotting a table that is online without flushing

Throws:

Exception

testFlushTableSnapshotWithProcedure

public void testFlushTableSnapshotWithProcedure()
                                         throws Exception

Test simple flush snapshotting a table that is online

Throws:

Exception

testSnapshotFailsOnNonExistantTable

public void testSnapshotFailsOnNonExistantTable()
                                         throws Exception

Throws:

Exception

waitForSnapshotToComplete

private static void waitForSnapshotToComplete(org.apache.hadoop.hbase.master.HMaster master,
 org.apache.hadoop.hbase.shaded.protobuf.generated.SnapshotProtos.SnapshotDescription snapshot,
 long timeoutNanos)
                                       throws Exception

Helper method for testing async snapshot operations. Just waits for the given snapshot to complete on the server by repeatedly checking the master.

Parameters:

master - the master running the snapshot

snapshot - the snapshot to check

timeoutNanos - the timeout in nano between checks to see if the snapshot is done

Throws:

Exception

testAsyncFlushSnapshot

public void testAsyncFlushSnapshot()
                            throws Exception

Throws:

Exception

testSnapshotStateAfterMerge

public void testSnapshotStateAfterMerge()
                                 throws Exception

Throws:

Exception

testTakeSnapshotAfterMerge

public void testTakeSnapshotAfterMerge()
                                throws Exception

Throws:

Exception

testFlushCreateListDestroy

public void testFlushCreateListDestroy()
                                throws Exception

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

Throws:

Exception

waitRegionsAfterMerge

private void waitRegionsAfterMerge(long numRegionsAfterMerge)
                            throws IOException,
InterruptedException

Throws:

IOException

InterruptedException

verifyRowCount

protected void verifyRowCount(HBaseTestingUtil 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