org.apache.hadoop.hbase.mapreduce

Class TableSnapshotInputFormatTestBase

java.lang.Object

org.apache.hadoop.hbase.mapreduce.TableSnapshotInputFormatTestBase

Direct Known Subclasses:

TestTableSnapshotInputFormat, TestTableSnapshotInputFormat

public abstract class TableSnapshotInputFormatTestBase
extends Object

Field Summary

Fields

Modifier and Type	Field and Description
protected static byte[][]	FAMILIES
protected org.apache.hadoop.fs.FileSystem	fs
private static org.slf4j.Logger	LOG
protected static int	NUM_REGION_SERVERS
protected org.apache.hadoop.fs.Path	rootDir
protected HBaseTestingUtility	UTIL

Constructor Summary

Constructors

Constructor and Description
TableSnapshotInputFormatTestBase()

Method Summary

Modifier and Type	Method and Description
protected static void	createTableAndSnapshot(HBaseTestingUtility util, org.apache.hadoop.hbase.TableName tableName, String snapshotName, byte[] startRow, byte[] endRow, int numRegions)
protected abstract byte[]	getEndRow()
protected abstract byte[]	getStartRow()
void	setupCluster()
private static void	setupConf(org.apache.hadoop.conf.Configuration conf)
void	tearDownCluster()
void	testRestoreSnapshotDoesNotCreateBackRefLinks()
abstract void	testRestoreSnapshotDoesNotCreateBackRefLinksInit(org.apache.hadoop.hbase.TableName tableName, String snapshotName, org.apache.hadoop.fs.Path tmpTableDir)
protected void	testWithMapReduce(HBaseTestingUtility util, String snapshotName, int numRegions, int numSplitsPerRegion, int expectedNumSplits, boolean shutdownCluster)
void	testWithMapReduceAndOfflineHBaseMultiRegion()
protected abstract void	testWithMapReduceImpl(HBaseTestingUtility util, org.apache.hadoop.hbase.TableName tableName, String snapshotName, org.apache.hadoop.fs.Path tableDir, int numRegions, int numSplitsPerRegion, int expectedNumSplits, boolean shutdownCluster)
void	testWithMapReduceMultiRegion()
void	testWithMapReduceSingleRegion()
protected abstract void	testWithMockedMapReduce(HBaseTestingUtility util, String snapshotName, int numRegions, int numSplitsPerRegion, int expectedNumSplits, boolean setLocalityEnabledTo)
void	testWithMockedMapReduceMultiRegion()
void	testWithMockedMapReduceSingleRegion()
protected static void	verifyRowFromMap(org.apache.hadoop.hbase.io.ImmutableBytesWritable key, org.apache.hadoop.hbase.client.Result result)

Methods inherited from class java.lang.Object

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

Field Detail

LOG

private static final org.slf4j.Logger LOG

UTIL

protected final HBaseTestingUtility UTIL

NUM_REGION_SERVERS

protected static final int NUM_REGION_SERVERS

See Also:

Constant Field Values

FAMILIES

protected static final byte[][] FAMILIES

fs

protected org.apache.hadoop.fs.FileSystem fs

rootDir

protected org.apache.hadoop.fs.Path rootDir

Constructor Detail

TableSnapshotInputFormatTestBase

public TableSnapshotInputFormatTestBase()

Method Detail

setupCluster

public void setupCluster()
                  throws Exception

Throws:

Exception

tearDownCluster

public void tearDownCluster()
                     throws Exception

Throws:

Exception

setupConf

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

testWithMockedMapReduce

protected abstract void testWithMockedMapReduce(HBaseTestingUtility util,
                                                String snapshotName,
                                                int numRegions,
                                                int numSplitsPerRegion,
                                                int expectedNumSplits,
                                                boolean setLocalityEnabledTo)
                                         throws Exception

Throws:

Exception

testWithMapReduceImpl

protected abstract void testWithMapReduceImpl(HBaseTestingUtility util,
                                              org.apache.hadoop.hbase.TableName tableName,
                                              String snapshotName,
                                              org.apache.hadoop.fs.Path tableDir,
                                              int numRegions,
                                              int numSplitsPerRegion,
                                              int expectedNumSplits,
                                              boolean shutdownCluster)
                                       throws Exception

Throws:

Exception

getStartRow

protected abstract byte[] getStartRow()

getEndRow

protected abstract byte[] getEndRow()

testWithMockedMapReduceSingleRegion

public void testWithMockedMapReduceSingleRegion()
                                         throws Exception

Throws:

Exception

testWithMockedMapReduceMultiRegion

public void testWithMockedMapReduceMultiRegion()
                                        throws Exception

Throws:

Exception

testWithMapReduceSingleRegion

public void testWithMapReduceSingleRegion()
                                   throws Exception

Throws:

Exception

testWithMapReduceMultiRegion

public void testWithMapReduceMultiRegion()
                                  throws Exception

Throws:

Exception

testWithMapReduceAndOfflineHBaseMultiRegion

public void testWithMapReduceAndOfflineHBaseMultiRegion()
                                                 throws Exception

Throws:

Exception

testRestoreSnapshotDoesNotCreateBackRefLinks

public void testRestoreSnapshotDoesNotCreateBackRefLinks()
                                                  throws Exception

Throws:

Exception

testRestoreSnapshotDoesNotCreateBackRefLinksInit

public abstract void testRestoreSnapshotDoesNotCreateBackRefLinksInit(org.apache.hadoop.hbase.TableName tableName,
                                                                      String snapshotName,
                                                                      org.apache.hadoop.fs.Path tmpTableDir)
                                                               throws Exception

Throws:

Exception

testWithMapReduce

protected void testWithMapReduce(HBaseTestingUtility util,
                                 String snapshotName,
                                 int numRegions,
                                 int numSplitsPerRegion,
                                 int expectedNumSplits,
                                 boolean shutdownCluster)
                          throws Exception

Throws:

Exception

verifyRowFromMap

protected static void verifyRowFromMap(org.apache.hadoop.hbase.io.ImmutableBytesWritable key,
                                       org.apache.hadoop.hbase.client.Result result)
                                throws IOException

Throws:

IOException

createTableAndSnapshot

protected static void createTableAndSnapshot(HBaseTestingUtility util,
                                             org.apache.hadoop.hbase.TableName tableName,
                                             String snapshotName,
                                             byte[] startRow,
                                             byte[] endRow,
                                             int numRegions)
                                      throws Exception

Throws:

Exception