Package org.apache.hadoop.hbase.snapshot

Class TestRestoreSnapshotHelper

java.lang.Object

org.apache.hadoop.hbase.snapshot.TestRestoreSnapshotHelper

Direct Known Subclasses:

TestMobRestoreSnapshotHelper

public class TestRestoreSnapshotHelper
extends Object

Test the restore/clone operation from a file-system point of view.

Field Summary

Fields

Modifier and Type	Field	Description
protected org.apache.hadoop.fs.Path	archiveDir
static final HBaseClassTestRule	CLASS_RULE
protected org.apache.hadoop.conf.Configuration	conf
protected org.apache.hadoop.fs.FileSystem	fs
private static final org.slf4j.Logger	LOG
protected org.apache.hadoop.fs.Path	rootDir
protected static final String	TEST_HFILE
protected static final HBaseTestingUtil	TEST_UTIL

Constructor Summary

Constructors

Constructor	Description
TestRestoreSnapshotHelper()

Method Summary

Modifier and Type	Method	Description
private void	checkNoHFileLinkInTableDir(org.apache.hadoop.hbase.TableName tableName)
protected SnapshotTestingUtils.SnapshotMock	createSnapshotMock()
protected void	createTableAndSnapshot(org.apache.hadoop.hbase.TableName tableName, String snapshotName)
private org.apache.hadoop.fs.Path	getReferredToFile(String referenceName)
private org.apache.hadoop.hbase.snapshot.RestoreSnapshotHelper	getRestoreHelper(org.apache.hadoop.fs.Path rootDir, org.apache.hadoop.fs.Path snapshotDir, org.apache.hadoop.hbase.shaded.protobuf.generated.SnapshotProtos.SnapshotDescription sd, org.apache.hadoop.hbase.client.TableDescriptor htdClone)	Initialize the restore helper, based on the snapshot and table information provided.
private boolean	hasHFileLink(org.apache.hadoop.fs.Path tableDir)
private void	restoreAndVerify(String snapshotName, String tableName)
void	setup()
static void	setupCluster()
protected void	setupConf(org.apache.hadoop.conf.Configuration conf)
void	tearDown()
static void	tearDownCluster()
void	testCopyExpiredSnapshotForScanner()
void	testNoHFileLinkInRootDir()
void	testRestore()
private void	testRestore(org.apache.hadoop.fs.Path snapshotDir, org.apache.hadoop.hbase.shaded.protobuf.generated.SnapshotProtos.SnapshotDescription sd, org.apache.hadoop.hbase.client.TableDescriptor htdClone)	Execute the restore operation
void	testRestoreWithNamespace()
void	testSkipReplayAndUpdateSeqId()
private void	verifyRestore(org.apache.hadoop.fs.Path rootDir, org.apache.hadoop.hbase.client.TableDescriptor sourceHtd, org.apache.hadoop.hbase.client.TableDescriptor htdClone)

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

TEST_UTIL

protected static final HBaseTestingUtil TEST_UTIL

TEST_HFILE

protected static final String TEST_HFILE

See Also:

• Constant Field Values

conf

protected org.apache.hadoop.conf.Configuration conf

archiveDir

protected org.apache.hadoop.fs.Path archiveDir

fs

protected org.apache.hadoop.fs.FileSystem fs

rootDir

protected org.apache.hadoop.fs.Path rootDir

Constructor Details

TestRestoreSnapshotHelper

public TestRestoreSnapshotHelper()

Method Details

setupConf

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

setupCluster

public static void setupCluster()
                         throws Exception

Throws:

Exception

tearDownCluster

public static void tearDownCluster()
                            throws Exception

Throws:

Exception

setup

public void setup()
           throws Exception

Throws:

Exception

tearDown

public void tearDown()
              throws Exception

Throws:

Exception

createSnapshotMock

protected SnapshotTestingUtils.SnapshotMock createSnapshotMock()
                                                        throws IOException

Throws:

IOException

testRestore

public void testRestore()
                 throws IOException

Throws:

IOException

testRestoreWithNamespace

public void testRestoreWithNamespace()
                              throws IOException

Throws:

IOException

testNoHFileLinkInRootDir

public void testNoHFileLinkInRootDir()
                              throws IOException

Throws:

IOException

testSkipReplayAndUpdateSeqId

public void testSkipReplayAndUpdateSeqId()
                                  throws Exception

Throws:

Exception

testCopyExpiredSnapshotForScanner

public void testCopyExpiredSnapshotForScanner()
                                       throws IOException,
InterruptedException

Throws:

IOException

InterruptedException

createTableAndSnapshot

protected void createTableAndSnapshot(org.apache.hadoop.hbase.TableName tableName,
 String snapshotName)
                               throws IOException

Throws:

IOException

checkNoHFileLinkInTableDir

private void checkNoHFileLinkInTableDir(org.apache.hadoop.hbase.TableName tableName)
                                 throws IOException

Throws:

IOException

hasHFileLink

private boolean hasHFileLink(org.apache.hadoop.fs.Path tableDir)
                      throws IOException

Throws:

IOException

restoreAndVerify

private void restoreAndVerify(String snapshotName,
 String tableName)
                       throws IOException

Throws:

IOException

verifyRestore

private void verifyRestore(org.apache.hadoop.fs.Path rootDir,
 org.apache.hadoop.hbase.client.TableDescriptor sourceHtd,
 org.apache.hadoop.hbase.client.TableDescriptor htdClone)
                    throws IOException

Throws:

IOException

testRestore

private void testRestore(org.apache.hadoop.fs.Path snapshotDir,
 org.apache.hadoop.hbase.shaded.protobuf.generated.SnapshotProtos.SnapshotDescription sd,
 org.apache.hadoop.hbase.client.TableDescriptor htdClone)
                  throws IOException

Execute the restore operation

Parameters:

snapshotDir - The snapshot directory to use as "restore source"

sd - The snapshot descriptor

htdClone - The HTableDescriptor of the table to restore/clone.

Throws:

IOException

getRestoreHelper

private org.apache.hadoop.hbase.snapshot.RestoreSnapshotHelper getRestoreHelper(org.apache.hadoop.fs.Path rootDir,
 org.apache.hadoop.fs.Path snapshotDir,
 org.apache.hadoop.hbase.shaded.protobuf.generated.SnapshotProtos.SnapshotDescription sd,
 org.apache.hadoop.hbase.client.TableDescriptor htdClone)
                                                                         throws IOException

Initialize the restore helper, based on the snapshot and table information provided.

Throws:

IOException

getReferredToFile

private org.apache.hadoop.fs.Path getReferredToFile(String referenceName)