org.apache.hadoop.hbase.mapred

Class TestTableSnapshotInputFormat

java.lang.Object

org.apache.hadoop.hbase.mapreduce.TableSnapshotInputFormatTestBase

org.apache.hadoop.hbase.mapred.TestTableSnapshotInputFormat

public class TestTableSnapshotInputFormat
extends TableSnapshotInputFormatTestBase

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static class	TestTableSnapshotInputFormat.TestTableSnapshotReducer

Field Summary

Fields

Modifier and Type	Field and Description
static HBaseClassTestRule	CLASS_RULE
TestName	name

Fields inherited from class org.apache.hadoop.hbase.mapreduce.TableSnapshotInputFormatTestBase

FAMILIES, fs, NUM_REGION_SERVERS, rootDir, UTIL

Constructor Summary

Constructors

Constructor and Description
TestTableSnapshotInputFormat()

Method Summary

Modifier and Type	Method and Description
static void	doTestWithMapReduce(HBaseTestingUtility util, TableName tableName, java.lang.String snapshotName, byte[] startRow, byte[] endRow, Path tableDir, int numRegions, int numSplitsPerRegion, int expectedNumSplits, boolean shutdownCluster)
protected byte[]	getEndRow()
protected byte[]	getStartRow()
void	testInitTableSnapshotMapperJobConfig()
void	testRestoreSnapshotDoesNotCreateBackRefLinksInit(TableName tableName, java.lang.String snapshotName, Path tmpTableDir)
void	testWithMapReduceAndOfflineHBaseMultiRegion()
protected void	testWithMapReduceImpl(HBaseTestingUtility util, TableName tableName, java.lang.String snapshotName, Path tableDir, int numRegions, int numSplitsPerRegion, int expectedNumSplits, boolean shutdownCluster)
void	testWithMapReduceMultiRegion()
protected void	testWithMockedMapReduce(HBaseTestingUtility util, java.lang.String snapshotName, int numRegions, int numSplitsPerRegion, int expectedNumSplits, boolean setLocalityEnabledTo)
void	testWithMockedMapReduceMultiRegion()

Methods inherited from class org.apache.hadoop.hbase.mapreduce.TableSnapshotInputFormatTestBase

createTableAndSnapshot, setupCluster, tearDownCluster, testRestoreSnapshotDoesNotCreateBackRefLinks, testWithMapReduce, testWithMapReduceMultipleMappersPerRegion, testWithMapReduceSingleRegion, testWithMockedMapReduceSingleRegion, verifyRowFromMap

Methods inherited from class java.lang.Object

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

Field Detail

CLASS_RULE

public static final HBaseClassTestRule CLASS_RULE

name

public TestName name

Constructor Detail

TestTableSnapshotInputFormat

public TestTableSnapshotInputFormat()

Method Detail

getStartRow

protected byte[] getStartRow()

Specified by:

getStartRow in class TableSnapshotInputFormatTestBase

getEndRow

protected byte[] getEndRow()

Specified by:

getEndRow in class TableSnapshotInputFormatTestBase

testInitTableSnapshotMapperJobConfig

public void testInitTableSnapshotMapperJobConfig()
                                          throws java.lang.Exception

Throws:

java.lang.Exception

testWithMockedMapReduceMultiRegion

public void testWithMockedMapReduceMultiRegion()
                                        throws java.lang.Exception

Overrides:

testWithMockedMapReduceMultiRegion in class TableSnapshotInputFormatTestBase

Throws:

java.lang.Exception

testWithMapReduceMultiRegion

public void testWithMapReduceMultiRegion()
                                  throws java.lang.Exception

Overrides:

testWithMapReduceMultiRegion in class TableSnapshotInputFormatTestBase

Throws:

java.lang.Exception

testWithMapReduceAndOfflineHBaseMultiRegion

public void testWithMapReduceAndOfflineHBaseMultiRegion()
                                                 throws java.lang.Exception

Overrides:

testWithMapReduceAndOfflineHBaseMultiRegion in class TableSnapshotInputFormatTestBase

Throws:

java.lang.Exception

testRestoreSnapshotDoesNotCreateBackRefLinksInit

public void testRestoreSnapshotDoesNotCreateBackRefLinksInit(TableName tableName,
                                                             java.lang.String snapshotName,
                                                             Path tmpTableDir)
                                                      throws java.lang.Exception

Specified by:

testRestoreSnapshotDoesNotCreateBackRefLinksInit in class TableSnapshotInputFormatTestBase

Throws:

java.lang.Exception

testWithMockedMapReduce

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

Specified by:

testWithMockedMapReduce in class TableSnapshotInputFormatTestBase

Throws:

java.lang.Exception

testWithMapReduceImpl

protected void testWithMapReduceImpl(HBaseTestingUtility util,
                                     TableName tableName,
                                     java.lang.String snapshotName,
                                     Path tableDir,
                                     int numRegions,
                                     int numSplitsPerRegion,
                                     int expectedNumSplits,
                                     boolean shutdownCluster)
                              throws java.lang.Exception

Specified by:

testWithMapReduceImpl in class TableSnapshotInputFormatTestBase

Throws:

java.lang.Exception

doTestWithMapReduce

public static void doTestWithMapReduce(HBaseTestingUtility util,
                                       TableName tableName,
                                       java.lang.String snapshotName,
                                       byte[] startRow,
                                       byte[] endRow,
                                       Path tableDir,
                                       int numRegions,
                                       int numSplitsPerRegion,
                                       int expectedNumSplits,
                                       boolean shutdownCluster)
                                throws java.lang.Exception

Throws:

java.lang.Exception