org.apache.hadoop.hbase.snapshot

Class SnapshotTestingUtils

java.lang.Object

org.apache.hadoop.hbase.snapshot.SnapshotTestingUtils

public class SnapshotTestingUtils
extends Object

Utilities class for snapshots

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static class	SnapshotTestingUtils.SnapshotMock

Constructor Summary

Constructors

Constructor and Description
SnapshotTestingUtils()

Method Summary

Modifier and Type	Method and Description
static List<HBaseProtos.SnapshotDescription>	assertExistsMatchingSnapshot(Admin admin, String snapshotName, TableName tableName) Make sure that there is only one snapshot returned from the master and its name and table match the passed in parameters.
static void	assertNoSnapshots(Admin admin) Assert that we don't have any snapshots lists
static List<HBaseProtos.SnapshotDescription>	assertOneSnapshotThatMatches(Admin admin, byte[] snapshot, TableName tableName) Make sure that there is only one snapshot returned from the master and its name and table match the passed in parameters.
static void	assertOneSnapshotThatMatches(Admin admin, HBaseProtos.SnapshotDescription snapshot) Make sure that there is only one snapshot returned from the master
static List<HBaseProtos.SnapshotDescription>	assertOneSnapshotThatMatches(Admin admin, String snapshotName, TableName tableName) Make sure that there is only one snapshot returned from the master and its name and table match the passed in parameters.
static void	cleanupSnapshot(Admin admin, byte[] tableName)
static void	cleanupSnapshot(Admin admin, String snapshotName)
static void	confirmEmptySnapshotValid(HBaseProtos.SnapshotDescription snapshotDescriptor, TableName tableName, byte[] testFamily, Path rootDir, Admin admin, FileSystem fs) Confirm that the snapshot has no references files but only metadata.
static void	confirmSnapshotValid(HBaseProtos.SnapshotDescription snapshotDescriptor, TableName tableName, byte[] testFamily, Path rootDir, Admin admin, FileSystem fs) Confirm that the snapshot contains references to all the files that should be in the snapshot.
static void	confirmSnapshotValid(HBaseProtos.SnapshotDescription snapshotDescriptor, TableName tableName, List<byte[]> nonEmptyTestFamilies, List<byte[]> emptyTestFamilies, Path rootDir, Admin admin, FileSystem fs) Confirm that the snapshot contains references to all the files that should be in the snapshot.
static ArrayList	corruptSnapshot(HBaseTestingUtility util, String snapshotName) Corrupt the specified snapshot by deleting some files.
static void	createSnapshotAndValidate(Admin admin, TableName tableName, List<byte[]> nonEmptyFamilyNames, List<byte[]> emptyFamilyNames, String snapshotNameString, Path rootDir, FileSystem fs, boolean onlineSnapshot) Take a snapshot of the specified table and verify the given families.
static void	createSnapshotAndValidate(Admin admin, TableName tableName, String familyName, String snapshotNameString, Path rootDir, FileSystem fs, boolean onlineSnapshot) Take a snapshot of the specified table and verify that the given family is not empty.
static void	createTable(HBaseTestingUtility util, TableName tableName, byte[]... families)
static void	createTable(HBaseTestingUtility util, TableName tableName, int regionReplication, byte[]... families)
static void	deleteAllSnapshots(Admin admin)
static void	deleteArchiveDirectory(HBaseTestingUtility util)
static void	expectSnapshotDoneException(HMaster master, MasterProtos.IsSnapshotDoneRequest snapshot, Class<? extends HBaseSnapshotException> clazz) Expect the snapshot to throw an error when checking if the snapshot is complete
static byte[][]	getSplitKeys()
static String[]	listHFileNames(FileSystem fs, Path tableDir)
static Path[]	listHFiles(FileSystem fs, Path tableDir) List all the HFiles in the given table
static void	loadData(HBaseTestingUtility util, BufferedMutator mutator, int rows, byte[]... families)
static void	loadData(HBaseTestingUtility util, TableName tableName, int rows, byte[]... families)
static void	snapshot(Admin admin, String snapshotName, String tableName, HBaseProtos.SnapshotDescription.Type type, int numTries)
static void	verifyReplicasCameOnline(TableName tableName, Admin admin, int regionReplication)
static void	verifyRowCount(HBaseTestingUtility util, TableName tableName, long expectedRows)
static void	waitForSnapshotToComplete(HMaster master, HBaseProtos.SnapshotDescription snapshot, long sleep) Helper method for testing async snapshot operations.
static void	waitForTableToBeOnline(HBaseTestingUtility util, TableName tableName)

Methods inherited from class java.lang.Object

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

Constructor Detail

SnapshotTestingUtils

public SnapshotTestingUtils()

Method Detail

assertNoSnapshots

public static void assertNoSnapshots(Admin admin)
                              throws IOException

Assert that we don't have any snapshots lists

Throws:

IOException - if the admin operation fails

assertExistsMatchingSnapshot

public static List<HBaseProtos.SnapshotDescription> assertExistsMatchingSnapshot(Admin admin,
                                                                                 String snapshotName,
                                                                                 TableName tableName)
                                                                          throws IOException

Make sure that there is only one snapshot returned from the master and its name and table match the passed in parameters.

Throws:

IOException

assertOneSnapshotThatMatches

public static void assertOneSnapshotThatMatches(Admin admin,
                                                HBaseProtos.SnapshotDescription snapshot)
                                         throws IOException

Make sure that there is only one snapshot returned from the master

Throws:

IOException

assertOneSnapshotThatMatches

public static List<HBaseProtos.SnapshotDescription> assertOneSnapshotThatMatches(Admin admin,
                                                                                 String snapshotName,
                                                                                 TableName tableName)
                                                                          throws IOException

Make sure that there is only one snapshot returned from the master and its name and table match the passed in parameters.

Throws:

IOException

assertOneSnapshotThatMatches

public static List<HBaseProtos.SnapshotDescription> assertOneSnapshotThatMatches(Admin admin,
                                                                                 byte[] snapshot,
                                                                                 TableName tableName)
                                                                          throws IOException

Make sure that there is only one snapshot returned from the master and its name and table match the passed in parameters.

Throws:

IOException

confirmSnapshotValid

public static void confirmSnapshotValid(HBaseProtos.SnapshotDescription snapshotDescriptor,
                                        TableName tableName,
                                        byte[] testFamily,
                                        Path rootDir,
                                        Admin admin,
                                        FileSystem fs)
                                 throws IOException

Confirm that the snapshot contains references to all the files that should be in the snapshot.

Throws:

IOException

confirmEmptySnapshotValid

public static void confirmEmptySnapshotValid(HBaseProtos.SnapshotDescription snapshotDescriptor,
                                             TableName tableName,
                                             byte[] testFamily,
                                             Path rootDir,
                                             Admin admin,
                                             FileSystem fs)
                                      throws IOException

Confirm that the snapshot has no references files but only metadata.

Throws:

IOException

confirmSnapshotValid

public static void confirmSnapshotValid(HBaseProtos.SnapshotDescription snapshotDescriptor,
                                        TableName tableName,
                                        List<byte[]> nonEmptyTestFamilies,
                                        List<byte[]> emptyTestFamilies,
                                        Path rootDir,
                                        Admin admin,
                                        FileSystem fs)
                                 throws IOException

Confirm that the snapshot contains references to all the files that should be in the snapshot. This method also perform some redundant check like the existence of the snapshotinfo or the regioninfo which are done always by the MasterSnapshotVerifier, at the end of the snapshot operation.

Throws:

IOException

waitForSnapshotToComplete

public static void waitForSnapshotToComplete(HMaster master,
                                             HBaseProtos.SnapshotDescription snapshot,
                                             long sleep)
                                      throws ServiceException

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

sleep: - amount to sleep between checks to see if the snapshot is done

Throws:

ServiceException - if the snapshot fails

snapshot

public static void snapshot(Admin admin,
                            String snapshotName,
                            String tableName,
                            HBaseProtos.SnapshotDescription.Type type,
                            int numTries)
                     throws IOException

Throws:

IOException

cleanupSnapshot

public static void cleanupSnapshot(Admin admin,
                                   byte[] tableName)
                            throws IOException

Throws:

IOException

cleanupSnapshot

public static void cleanupSnapshot(Admin admin,
                                   String snapshotName)
                            throws IOException

Throws:

IOException

expectSnapshotDoneException

public static void expectSnapshotDoneException(HMaster master,
                                               MasterProtos.IsSnapshotDoneRequest snapshot,
                                               Class<? extends HBaseSnapshotException> clazz)

Expect the snapshot to throw an error when checking if the snapshot is complete

Parameters:

master - master to check

snapshot - the HBaseProtos.SnapshotDescription request to pass to the master

clazz - expected exception from the master

listHFiles

public static Path[] listHFiles(FileSystem fs,
                                Path tableDir)
                         throws IOException

List all the HFiles in the given table

Parameters:

fs: - FileSystem where the table lives

tableDir - directory of the table

Returns:

array of the current HFiles in the table (could be a zero-length array)

Throws:

IOException - on unexecpted error reading the FS

listHFileNames

public static String[] listHFileNames(FileSystem fs,
                                      Path tableDir)
                               throws IOException

Throws:

IOException

createSnapshotAndValidate

public static void createSnapshotAndValidate(Admin admin,
                                             TableName tableName,
                                             String familyName,
                                             String snapshotNameString,
                                             Path rootDir,
                                             FileSystem fs,
                                             boolean onlineSnapshot)
                                      throws Exception

Take a snapshot of the specified table and verify that the given family is not empty. Note that this will leave the table disabled in the case of an offline snapshot.

Throws:

Exception

createSnapshotAndValidate

public static void createSnapshotAndValidate(Admin admin,
                                             TableName tableName,
                                             List<byte[]> nonEmptyFamilyNames,
                                             List<byte[]> emptyFamilyNames,
                                             String snapshotNameString,
                                             Path rootDir,
                                             FileSystem fs,
                                             boolean onlineSnapshot)
                                      throws Exception

Take a snapshot of the specified table and verify the given families. Note that this will leave the table disabled in the case of an offline snapshot.

Throws:

Exception

corruptSnapshot

public static ArrayList corruptSnapshot(HBaseTestingUtility util,
                                        String snapshotName)
                                 throws IOException

Corrupt the specified snapshot by deleting some files.

Parameters:

util - HBaseTestingUtility

snapshotName - name of the snapshot to corrupt

Returns:

array of the corrupted HFiles

Throws:

IOException - on unexecpted error reading the FS

waitForTableToBeOnline

public static void waitForTableToBeOnline(HBaseTestingUtility util,
                                          TableName tableName)
                                   throws IOException,
                                          InterruptedException

Throws:

IOException

InterruptedException

createTable

public static void createTable(HBaseTestingUtility util,
                               TableName tableName,
                               int regionReplication,
                               byte[]... families)
                        throws IOException,
                               InterruptedException

Throws:

IOException

InterruptedException

getSplitKeys

public static byte[][] getSplitKeys()

createTable

public static void createTable(HBaseTestingUtility util,
                               TableName tableName,
                               byte[]... families)
                        throws IOException,
                               InterruptedException

Throws:

IOException

InterruptedException

loadData

public static void loadData(HBaseTestingUtility util,
                            TableName tableName,
                            int rows,
                            byte[]... families)
                     throws IOException,
                            InterruptedException

Throws:

IOException

InterruptedException

loadData

public static void loadData(HBaseTestingUtility util,
                            BufferedMutator mutator,
                            int rows,
                            byte[]... families)
                     throws IOException,
                            InterruptedException

Throws:

IOException

InterruptedException

deleteAllSnapshots

public static void deleteAllSnapshots(Admin admin)
                               throws IOException

Throws:

IOException

deleteArchiveDirectory

public static void deleteArchiveDirectory(HBaseTestingUtility util)
                                   throws IOException

Throws:

IOException

verifyRowCount

public static void verifyRowCount(HBaseTestingUtility util,
                                  TableName tableName,
                                  long expectedRows)
                           throws IOException

Throws:

IOException

verifyReplicasCameOnline

public static void verifyReplicasCameOnline(TableName tableName,
                                            Admin admin,
                                            int regionReplication)
                                     throws IOException

Throws:

IOException